Change auto-scaler confusing log message

This commit is contained in:
allegroai 2022-01-31 10:51:25 +02:00
parent f45b3e3ce3
commit 4b30ac6c31

View File

@ -288,9 +288,10 @@ class AutoScaler(object):
resource = WorkerId(worker_id).name resource = WorkerId(worker_id).name
queue = self.resource_to_queue[resource] queue = self.resource_to_queue[resource]
suffix = ', task_id={!r}'.format(task_id) if task_id else ''
self.logger.info( self.logger.info(
'Spinning new instance resource=%r, prefix=%r, queue=%r, task_id=%r', 'Spinning new instance resource=%r, prefix=%r, queue=%r%s',
resource, self.workers_prefix, queue, task_id) resource, self.workers_prefix, queue, suffix)
resource_conf = self.resource_configurations[resource] resource_conf = self.resource_configurations[resource]
worker_prefix = self.gen_worker_prefix(resource, resource_conf) worker_prefix = self.gen_worker_prefix(resource, resource_conf)
instance_id = self.driver.spin_up_worker(resource_conf, worker_prefix, queue, task_id=task_id) instance_id = self.driver.spin_up_worker(resource_conf, worker_prefix, queue, task_id=task_id)