From 2f3d7b17f669bcae66f364db31fd627ac7084ed1 Mon Sep 17 00:00:00 2001 From: Matthew Jones Date: Thu, 26 Apr 2018 09:11:08 -0400 Subject: [PATCH] Fix an issue where missing instance group would cause an error We'll now default to queue submission to the basic management queue --- awx/main/scheduler/task_manager.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/awx/main/scheduler/task_manager.py b/awx/main/scheduler/task_manager.py index b3d5ed14f1..34aa80fe6f 100644 --- a/awx/main/scheduler/task_manager.py +++ b/awx/main/scheduler/task_manager.py @@ -277,7 +277,11 @@ class TaskManager(): def post_commit(): task.websocket_emit_status(task.status) if task.status != 'failed': - task.start_celery_task(opts, error_callback=error_handler, success_callback=success_handler, queue=rampart_group.name) + if rampart_group is not None: + actual_queue=rampart_group.name + else: + actual_queue=settings.CELERY_DEFAULT_QUEUE + task.start_celery_task(opts, error_callback=error_handler, success_callback=success_handler, queue=actual_queue) connection.on_commit(post_commit)