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

Add missing trigger for failed-to-start nodes (#13802)

Browse Source
This commit is contained in:
Alan Rominger
2023-07-24 12:17:46 -04:00
committed by GitHub
parent 53a7b7818e
commit 98bfe3f43f
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
awx/main/scheduler/task_manager.py
View File

@@ -165,7 +165,6 @@ class WorkflowManager(TaskBase):
logger.warning("Workflow manager has reached time out while processing running workflows, exiting loop early") logger.warning("Workflow manager has reached time out while processing running workflows, exiting loop early")
ScheduleWorkflowManager().schedule() ScheduleWorkflowManager().schedule()
# Do not process any more workflow jobs. Stop here. # Do not process any more workflow jobs. Stop here.
# Maybe we should schedule another WorkflowManager run
break break
dag = WorkflowDAG(workflow_job) dag = WorkflowDAG(workflow_job)
status_changed = False status_changed = False
@@ -180,8 +179,8 @@ class WorkflowManager(TaskBase):
workflow_job.save(update_fields=['status', 'start_args']) workflow_job.save(update_fields=['status', 'start_args'])
status_changed = True status_changed = True
else: else:
workflow_nodes = dag.mark_dnr_nodes() dnr_nodes = dag.mark_dnr_nodes()
WorkflowJobNode.objects.bulk_update(workflow_nodes, ['do_not_run']) WorkflowJobNode.objects.bulk_update(dnr_nodes, ['do_not_run'])
# If workflow is now done, we do special things to mark it as done. # If workflow is now done, we do special things to mark it as done.
is_done = dag.is_workflow_done() is_done = dag.is_workflow_done()
if is_done: if is_done:
@@ -261,6 +260,7 @@ class WorkflowManager(TaskBase):
job.status = 'failed' job.status = 'failed'
job.save(update_fields=['status', 'job_explanation']) job.save(update_fields=['status', 'job_explanation'])
job.websocket_emit_status('failed') job.websocket_emit_status('failed')
ScheduleWorkflowManager().schedule()
# TODO: should we emit a status on the socket here similar to tasks.py awx_periodic_scheduler() ? # TODO: should we emit a status on the socket here similar to tasks.py awx_periodic_scheduler() ?
# emit_websocket_notification('/socket.io/jobs', '', dict(id=)) # emit_websocket_notification('/socket.io/jobs', '', dict(id=))