External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-05-23 08:37:48 -02:30
Code Issues Packages Projects Releases Wiki Activity

Protect Tower from Ansible core making changes to the event uuids

Browse Source
This commit is contained in:
Matthew Jones
2017-02-13 11:54:41 -05:00
parent 0548a2ba75
commit 8c4d4a0543
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -70,8 +70,11 @@ class CallbackBrokerWorker(ConsumerMixin):
callbacks=[self.process_task])] callbacks=[self.process_task])]
def process_task(self, body, message): def process_task(self, body, message):
if "uuid" in body: if "uuid" in body and body['uuid']:
queue = UUID(body['uuid']).int % settings.JOB_EVENT_WORKERS try:
queue = UUID(body['uuid']).int % settings.JOB_EVENT_WORKERS
except Exception:
queue = self.total_messages % settings.JOB_EVENT_WORKERS
else: else:
queue = self.total_messages % settings.JOB_EVENT_WORKERS queue = self.total_messages % settings.JOB_EVENT_WORKERS
self.write_queue_worker(queue, body) self.write_queue_worker(queue, body)