External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-05-08 09:57:35 -02:30
Code Issues Packages Projects Releases Wiki Activity

all parents should finish before start child

Browse Source
This commit is contained in:
chris meyers
2018-10-17 10:16:40 -04:00
committed by mabashian
parent 77661c6032
commit 914892c3ac
1 changed files with 37 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
awx/main/scheduler/dag_workflow.py
View File

@@ -24,32 +24,50 @@ class WorkflowDAG(SimpleDAG):
for related_node in related_nodes: for related_node in related_nodes:
self.add_edge(workflow_node, related_node, node_type) self.add_edge(workflow_node, related_node, node_type)
'''
Determine if all, relevant, parents node are finished.
Relevant parents are parents that are marked do_not_run False.
:param node: a node entry from SimpleDag.nodes (i.e. a dict with property ['node_object']
Return a boolean
'''
def are_relevant_parents_finished(self, node):
obj = node['node_object']
parent_nodes = [p['node_object'] for p in self.get_dependents(obj)]
for p in parent_nodes:
if p.do_not_run is True:
continue
# Node might run a job
if p.do_not_run is False and not p.job:
return False
# Node decidedly got a job; check if job is done
if p.job and p.job.status not in ['successful', 'failed']:
return False
return True
def bfs_nodes_to_run(self): def bfs_nodes_to_run(self):
root_nodes = self.get_root_nodes() nodes = self.get_root_nodes()
nodes = root_nodes
nodes_found = [] nodes_found = []
for index, n in enumerate(nodes): for index, n in enumerate(nodes):
obj = n['node_object'] obj = n['node_object']
job = obj.job
if not job and obj.do_not_run is False: if obj.do_not_run is True:
nodes_found.append(n)
# Job is about to run or is running. Hold our horses and wait for
# the job to finish. We can't proceed down the graph path until we
# have the job result.
elif job and job.status not in ['failed', 'successful']:
continue continue
elif job and job.status == 'failed':
children_failed = self.get_dependencies(obj, 'failure_nodes') if obj.job:
children_always = self.get_dependencies(obj, 'always_nodes') if obj.job.status == 'failed':
children_all = children_failed + children_always nodes.extend(self.get_dependencies(obj, 'failure_nodes') +
nodes.extend(children_all) self.get_dependencies(obj, 'always_nodes'))
elif job and job.status == 'successful': elif obj.job.status == 'successful':
children_success = self.get_dependencies(obj, 'success_nodes') nodes.extend(self.get_dependencies(obj, 'success_nodes') +
children_always = self.get_dependencies(obj, 'always_nodes') self.get_dependencies(obj, 'always_nodes'))
children_all = children_success + children_always else:
nodes.extend(children_all) if self.are_relevant_parents_finished(n):
nodes_found.append(n)
return [n['node_object'] for n in nodes_found] return [n['node_object'] for n in nodes_found]
def cancel_node_jobs(self): def cancel_node_jobs(self):