85197deece837a1f4ffdbbffb72af6028a9b6e32,python/ray/autoscaler/_private/resource_demand_scheduler.py,ResourceDemandScheduler,_infer_legacy_node_resources_if_needed,#ResourceDemandScheduler#Any#,201

Before Change

                iter(max_resources_by_ip.values()))
        // We fill the worker node resources only once.
        if not self.node_types[NODE_TYPE_LEGACY_WORKER]["resources"]:
            if len(max_resources_by_ip) > 1:
                // Set the node_types here as we already launched a worker node
                // from which we directly get the node_resources.
                worker_nodes = self.provider.non_terminated_nodes(
                    tag_filters={TAG_RAY_NODE_KIND: NODE_KIND_WORKER})
                worker_node_ips = [
                    self.provider.internal_ip(node_id)
                    for node_id in worker_nodes
                ]
                for ip in worker_node_ips:
                    if ip in max_resources_by_ip:
                        self.node_types[NODE_TYPE_LEGACY_WORKER][
                            "resources"] = max_resources_by_ip[ip]
                assert self.node_types[NODE_TYPE_LEGACY_WORKER]["resources"]

    def _get_concurrent_resource_demand_to_launch(
            self,
            to_launch: Dict[NodeType, int],
            connected_nodes: List[NodeIP],

After Change

        
        // We fill the head node resources only once.
        if not self.node_types[NODE_TYPE_LEGACY_HEAD]["resources"]:
            try:
                head_ip = self.provider.internal_ip(
                    self.provider.non_terminated_nodes({
                        TAG_RAY_NODE_KIND: NODE_KIND_HEAD
                    })[0])
                self.node_types[NODE_TYPE_LEGACY_HEAD]["resources"] = \
                    copy.deepcopy(max_resources_by_ip[head_ip])
            except (IndexError, KeyError):
                logger.exception("Could not reach the head node.")
        // We fill the worker node resources only once.
        if not self.node_types[NODE_TYPE_LEGACY_WORKER]["resources"]:
            // Set the node_types here in case we already launched a worker node
            // from which we can directly get the node_resources.
            worker_nodes = self.provider.non_terminated_nodes(

Instances