85197deece837a1f4ffdbbffb72af6028a9b6e32,python/ray/autoscaler/_private/resource_demand_scheduler.py,ResourceDemandScheduler,_legacy_worker_node_to_launch,#ResourceDemandScheduler#Any#Any#Any#Any#,172

Before Change

        
        if self.max_workers == 0:
            return {}
        elif pending_nodes or len(nodes) > 1:
            // If we are already launching a worker node.
            // If first worker node fails this will never launch more nodes.
            return {}

After Change

        workers, it returns max(1, min_workers) worker nodes from which we
        later calculate the node resources.
        
        worker_nodes = self.provider.non_terminated_nodes(
            tag_filters={TAG_RAY_NODE_KIND: NODE_KIND_WORKER})
        if self.max_workers == 0:
            return {}
        elif sum(launching_nodes.values()) + len(worker_nodes) > 0:
            // If we are already launching a worker node, wait for its resources

Instances