From 475c90fd006ee77b8e6d297045daf07ec3b2b0a3 Mon Sep 17 00:00:00 2001 From: chris meyers Date: Fri, 19 Oct 2018 14:58:32 -0400 Subject: [PATCH] prevent job launching twice --- 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 0dbcab23e2..f973fcf4d8 100644 --- a/awx/main/scheduler/dag_workflow.py +++ b/awx/main/scheduler/dag_workflow.py @@ -51,9 +51,13 @@ class WorkflowDAG(SimpleDAG): def bfs_nodes_to_run(self): nodes = self.get_root_nodes() nodes_found = [] + 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) if obj.do_not_run is True: continue