From b8c6414dda1ee5b825cb6cf79df551aec8716255 Mon Sep 17 00:00:00 2001 From: Elijah DeLee Date: Wed, 2 Feb 2022 15:07:49 -0500 Subject: [PATCH] fix misleading message the variables and wording were both misleading, fix to be more accurate description in the two different cases where this log may be emitted. --- awx/main/scheduler/task_manager.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/awx/main/scheduler/task_manager.py b/awx/main/scheduler/task_manager.py index 24dba281a693..221959243de7 100644 --- a/awx/main/scheduler/task_manager.py +++ b/awx/main/scheduler/task_manager.py @@ -286,8 +286,10 @@ def start_task(self, task, rampart_group, dependent_tasks=None, instance=None): # at this point we already have control/execution nodes selected for the following cases else: task.instance_group = rampart_group - queue_submitted_to = task.execution_node if task.execution_node else rampart_group.name - logger.debug(f'Submitting job {task.log_format} to queue {queue_submitted_to} controlled by {task.controller_node}.') + execution_node_msg = f' and execution node {task.execution_node}' if task.execution_node else '' + logger.debug( + f'Submitting job {task.log_format} controlled by {task.controller_node} to instance group {rampart_group.name}{execution_node_msg}.' + ) with disable_activity_stream(): task.celery_task_id = str(uuid.uuid4()) task.save()