diff --git a/awx/main/scheduler/dag_workflow.py b/awx/main/scheduler/dag_workflow.py
index 510e87cf44..c872e3a712 100644
--- a/awx/main/scheduler/dag_workflow.py
+++ b/awx/main/scheduler/dag_workflow.py
@@ -108,9 +108,13 @@ class WorkflowDAG(SimpleDAG):
         root_nodes = self.get_root_nodes()
         nodes = copy.copy(root_nodes)
         nodes_marked_do_not_run = []
+        node_ids_visited = set()
 
         for index, n in enumerate(nodes):
             obj = n['node_object']
+            if obj.id in node_ids_visited:
+                continue
+            node_ids_visited.add(obj.id)
             job = obj.job
 
             if not job and obj.do_not_run is False and n not in root_nodes: