diff --git a/awx/main/scheduler/dag_workflow.py b/awx/main/scheduler/dag_workflow.py
index b49cf185e9..510e87cf44 100644
--- a/awx/main/scheduler/dag_workflow.py
+++ b/awx/main/scheduler/dag_workflow.py
@@ -133,10 +133,9 @@ class WorkflowDAG(SimpleDAG):
                 nodes.extend(children_all)
             elif job and job.status == 'failed':
                 children_failed = self.get_dependencies(obj, 'success_nodes')
-                children_all = children_failed
-                nodes.extend(children_all)
+                nodes.extend(children_failed)
             elif job and job.status == 'successful':
                 children_success = self.get_dependencies(obj, 'failure_nodes')
-                children_all = children_success
-                nodes.extend(children_all)
+                nodes.extend(children_success)
         return [n['node_object'] for n in nodes_marked_do_not_run]
+
diff --git a/awx/main/tests/functional/models/test_workflow.py b/awx/main/tests/functional/models/test_workflow.py
index cc44a9b621..f406085aca 100644
--- a/awx/main/tests/functional/models/test_workflow.py
+++ b/awx/main/tests/functional/models/test_workflow.py
@@ -102,8 +102,6 @@ class TestWorkflowDAGFunctional(TransactionTestCase):
 
 @pytest.mark.django_db
 class TestWorkflowDNR():
-    'success', 'new'
-
     @pytest.fixture
     def workflow_job_fn(self):
         def fn(states=['new', 'new', 'new', 'new', 'new', 'new']):