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

Before Change

                ]
                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"]

After Change

            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])

Instances