diff --git a/awx/main/management/commands/run_callback_receiver.py b/awx/main/management/commands/run_callback_receiver.py index ad102a5245..595e1f850e 100644 --- a/awx/main/management/commands/run_callback_receiver.py +++ b/awx/main/management/commands/run_callback_receiver.py @@ -103,10 +103,10 @@ class CallbackReceiver(object): for queue_actual in queue_order: try: worker_actual = worker_queues[queue_actual] - worker_queues[queue_actual][1].put(message, block=True, timeout=2) - worker_queues[queue_actual][0] += 1 + worker_actual[1].put(message, block=True, timeout=2) + worker_actual[0] += 1 return queue_actual - except Exception, e: + except Exception: logger.warn("Could not write to queue %s" % preferred_queue) continue return None