External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-01-24 07:51:23 -03:30
Code Issues Packages Projects Releases Wiki Activity

Fix flake8 warnings

Browse Source
This commit is contained in:
Matthew Jones 2015-03-13 13:30:45 -04:00
parent 446e15314c
commit bed6f6db5e
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -103,10 +103,10 @@ class CallbackReceiver(object):
for queue_actual in queue_order: for queue_actual in queue_order:
try: try:
worker_actual = worker_queues[queue_actual] worker_actual = worker_queues[queue_actual]
worker_queues[queue_actual][1].put(message, block=True, timeout=2) worker_actual[1].put(message, block=True, timeout=2)
worker_queues[queue_actual][0] += 1 worker_actual[0] += 1
return queue_actual return queue_actual
except Exception, e: except Exception:
logger.warn("Could not write to queue %s" % preferred_queue) logger.warn("Could not write to queue %s" % preferred_queue)
continue continue
return None return None