External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-04-05 01:59:25 -02:30
Code Issues Packages Projects Releases Wiki Activity

Avoid reaping tentative jobs

Browse Source
This commit is contained in:
Alan Rominger
2021-10-18 15:35:23 -04:00
committed by Shane McDonald
parent 55059b015f
commit 47e67481b3
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
awx/main/tasks.py
View File

@@ -667,13 +667,13 @@ def awx_receptor_workunit_reaper():
logger.exception(f'Unexpected error releasing work unit {job.work_unit_id}') 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 = [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( 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 work_unit_id__in=active_unit_ids
) )
for job in jobs_without_active_work_unit: for job in jobs_without_active_work_unit:
# TODO: skip if events came in recently
job.cancel_flag = True job.cancel_flag = True
job.status = 'error' job.status = 'error'
if job.work_unit_id in receptor_work_list: if job.work_unit_id in receptor_work_list: