Fix incorrect timeout used for stale workers

This commit is contained in:
allegroai 2022-02-02 15:31:37 +02:00
parent 5f1345b148
commit 051998800c

View File

@ -181,7 +181,7 @@ class AutoScaler(object):
def stale_workers(self, spun_workers):
now = time()
for worker_id, (resource, spin_time) in list(spun_workers.items()):
if now - spin_time > self.max_idle_time_min*60:
if now - spin_time > self.max_spin_up_time_min*60:
self.logger.info('Stuck spun instance %s of type %s', worker_id, resource)
yield worker_id