External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-04-05 01:59:25 -02:30
Code Issues Packages Projects Releases Wiki Activity

Change lazy worker method name and adjust log

Browse Source
This commit is contained in:
Alan Rominger
2022-07-28 09:16:08 -04:00
parent a9170236e1
commit c5985c4c81
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
awx/main/dispatch/pool.py
View File

@@ -195,7 +195,7 @@ class PoolWorker(object):
return not self.busy return not self.busy
@property @property
def lazy(self): def ready_to_scale_down(self):
if self.busy: if self.busy:
return False return False
if self.last_finished is None: if self.last_finished is None:
@@ -398,12 +398,12 @@ class AutoscalePool(WorkerPool):
logger.exception('failed to reap job UUID {}'.format(w.current_task['uuid'])) logger.exception('failed to reap job UUID {}'.format(w.current_task['uuid']))
orphaned.extend(w.orphaned_tasks) orphaned.extend(w.orphaned_tasks)
self.workers.remove(w) self.workers.remove(w)
elif w.lazy and len(self.workers) > self.min_workers: elif (len(self.workers) > self.min_workers) and w.ready_to_scale_down:
# the process has an empty queue (it's idle) and we have # the process has an empty queue (it's idle) and we have
# more processes in the pool than we need (> min) # more processes in the pool than we need (> min)
# send this process a message so it will exit gracefully # send this process a message so it will exit gracefully
# at the next opportunity # at the next opportunity
logger.info(f'scaling down worker pid:{w.pid} from:{len(self.workers)}') logger.info(f'scaling down worker pid:{w.pid} prior total:{len(self.workers)}')
w.quit() w.quit()
self.workers.remove(w) self.workers.remove(w)
if w.alive: if w.alive: