prevent job launching twice

This commit is contained in:
chris meyers 2018-10-19 14:58:32 -04:00 committed by mabashian
parent 2742b00a65
commit 475c90fd00

View File

@ -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