External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-02-28 16:28:43 -03:30
Code Issues Packages Projects Releases Wiki Activity

close DB and cache sockets _immediately_ before we fork callback workers

Browse Source
This commit is contained in:
Ryan Petrello
2018-08-15 14:18:52 -04:00
parent 63d7abc7e4
commit 87adfe5889
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
awx/main/management/commands/run_callback_receiver.py
View File

@@ -64,15 +64,22 @@ class CallbackBrokerWorker(ConsumerMixin):
return _handler return _handler
if use_workers: if use_workers:
django_connection.close()
django_cache.close()
for idx in range(settings.JOB_EVENT_WORKERS): for idx in range(settings.JOB_EVENT_WORKERS):
queue_actual = MPQueue(settings.JOB_EVENT_MAX_QUEUE_SIZE) queue_actual = MPQueue(settings.JOB_EVENT_MAX_QUEUE_SIZE)
w = Process(target=self.callback_worker, args=(queue_actual, idx,)) w = Process(target=self.callback_worker, args=(queue_actual, idx,))
w.start()
if settings.DEBUG: if settings.DEBUG:
logger.info('Started worker %s' % str(idx)) logger.info('Starting worker %s' % str(idx))
self.worker_queues.append([0, queue_actual, w]) self.worker_queues.append([0, queue_actual, w])
# It's important to close these _right before_ we fork; we
# don't want the forked processes to inherit the open sockets
# for the DB and memcached connections (that way lies race
# conditions)
django_connection.close()
django_cache.close()
for _, _, w in self.worker_queues:
w.start()
elif settings.DEBUG: elif settings.DEBUG:
logger.warn('Started callback receiver (no workers)') logger.warn('Started callback receiver (no workers)')