diff --git a/awx/main/scheduler/task_manager.py b/awx/main/scheduler/task_manager.py
index 16aa99ee08..f1d447077e 100644
--- a/awx/main/scheduler/task_manager.py
+++ b/awx/main/scheduler/task_manager.py
@@ -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)