From 081ce23b7df1e922c0d045abf33549b81467b8ac 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 d325b12b51..4a4090aec6 100644 --- a/awx/main/tasks.py +++ b/awx/main/tasks.py @@ -663,13 +663,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: