@@ -848,7 +848,11 @@ def _best_effort_node_assignment(
848848 # No instances launched at all, e.g. CreateFleet API returns no EC2 instances,
849849 # or no left instances available from a best-effort EC2 launch
850850 logger .info ("No launched instances found for nodes %s" , print_with_count (nodes_resume_list ))
851- self ._update_failed_nodes (set (nodes_resume_list ), "InsufficientInstanceCapacity(Check slurm_resume log for ec2 error codes)" , override = False )
851+ self ._update_failed_nodes (
852+ set (nodes_resume_list ),
853+ "InsufficientInstanceCapacity(Check slurm_resume log for ec2 error codes)" ,
854+ override = False ,
855+ )
852856
853857 def _all_or_nothing_node_assignment (
854858 self ,
@@ -903,7 +907,11 @@ def _all_or_nothing_node_assignment(
903907 # No instances launched at all, e.g. CreateFleet API returns no EC2 instances,
904908 # or no left instances available from a best-effort EC2 launch
905909 logger .info ("No launched instances found for nodes %s" , print_with_count (nodes_resume_list ))
906- self ._update_failed_nodes (set (nodes_resume_list ), "InsufficientInstanceCapacity(Check slurm_resume log for ec2 error codes)" , override = False )
910+ self ._update_failed_nodes (
911+ set (nodes_resume_list ),
912+ "InsufficientInstanceCapacity(Check slurm_resume log for ec2 error codes)" ,
913+ override = False ,
914+ )
907915
908916 def _launch_instances ( # noqa: C901
909917 self ,
@@ -986,7 +994,9 @@ def _launch_ec2_instances(self, batch_nodes, compute_resource, fleet_manager, in
986994 # queue_2: {cr_3: list[EC2Instance]}
987995 # }
988996 else :
989- self ._update_failed_nodes (set (batch_nodes ), "InsufficientInstanceCapacity(Check slurm_resume log for ec2 error codes)" )
997+ self ._update_failed_nodes (
998+ set (batch_nodes ), "InsufficientInstanceCapacity(Check slurm_resume log for ec2 error codes)"
999+ )
9901000 return launched_ec2_instances
9911001
9921002 def _get_fleet_manager (self , all_or_nothing_batch , compute_resource , queue ):
0 commit comments