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 {}
else:
After Change
resource_demands)
workers_to_add = min(
self.node_types[NODE_TYPE_LEGACY_WORKER].get("min_workers", 0),
self.node_types[NODE_TYPE_LEGACY_WORKER].get("max_workers", 0))
if workers_to_add > 0 or unfulfilled:
return {NODE_TYPE_LEGACY_WORKER: max(1, workers_to_add)}
else: