From a541efeaadd73dddbccbbf8479d7a95bd40f5223 Mon Sep 17 00:00:00 2001 From: chris meyers Date: Thu, 11 Oct 2018 13:49:05 -0400 Subject: [PATCH] only visit nodes once for dnr --- awx/main/scheduler/dag_workflow.py | 4 ++++ 1 file changed, 4 insertions(+) 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: