always find and mark dnr nodes

This commit is contained in:
chris meyers 2018-10-11 16:48:50 -04:00 committed by mabashian
parent 3506b9a7d8
commit ebabec0dad

View File

@ -173,9 +173,9 @@ class TaskManager():
status_changed = True
else:
is_done, has_failed = dag.is_workflow_done()
workflow_nodes = dag.mark_dnr_nodes()
map(lambda n: n.save(update_fields=['do_not_run']), workflow_nodes)
if not is_done:
workflow_nodes = dag.mark_dnr_nodes()
map(lambda n: n.save(update_fields=['do_not_run']), workflow_nodes)
continue
logger.info('Marking %s as %s.', workflow_job.log_format, 'failed' if has_failed else 'successful')
result.append(workflow_job.id)