From 47e67481b3159e4b80bef801637e243141bc1c1e Mon Sep 17 00:00:00 2001 From: Alan Rominger Date: Mon, 18 Oct 2021 15:35:23 -0400 Subject: [PATCH] Avoid reaping tentative jobs --- awx/main/tasks.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/awx/main/tasks.py b/awx/main/tasks.py index b05e9ad719..b83c440d09 100644 --- a/awx/main/tasks.py +++ b/awx/main/tasks.py @@ -667,13 +667,13 @@ def awx_receptor_workunit_reaper(): logger.exception(f'Unexpected error releasing work unit {job.work_unit_id}') active_unit_ids = [id for (id, data) in receptor_work_list.items() if data.get('StateName') in RECEPTOR_ACTIVE_STATES] + active_unit_ids.append('') # exclude jobs that have not yet started a receptor work unit jobs_without_active_work_unit = UnifiedJob.objects.filter(status__in=ACTIVE_STATES, controller_node=settings.CLUSTER_HOST_ID).exclude( work_unit_id__in=active_unit_ids ) for job in jobs_without_active_work_unit: - # TODO: skip if events came in recently job.cancel_flag = True job.status = 'error' if job.work_unit_id in receptor_work_list: