in src/slurm_plugin/instance_manager.py [0:0]
def _terminate_unassigned_launched_instances(self, terminate_batch_size):
# If there are remaining unassigned instances, terminate them
unassigned_launched_instances = [
instance
for compute_resources in self.unused_launched_instances.values()
for instance_list in compute_resources.values()
for instance in instance_list
]
if unassigned_launched_instances:
logger.info("Terminating unassigned launched instances: %s", self.unused_launched_instances)
self.delete_instances(
[instance.id for instance in unassigned_launched_instances],
terminate_batch_size,
)
self._clear_unused_launched_instances()