External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-01-21 22:48:02 -03:30
Code Issues Packages Projects Releases Wiki Activity

fixed issue where successful convergence wasn't being met due to the not quite correct leveraging of get_children

Browse Source
This commit is contained in:
Rebeccah 2020-01-17 01:35:26 -05:00
parent 987fc26537
commit 86a39938fe
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -78,8 +78,6 @@ class WorkflowDAG(SimpleDAG):
if obj.id in node_ids_visited:
continue
node_ids_visited.add(obj.id)
# import sdb
# sdb.set_trace()
if obj.do_not_run is True:
continue
elif obj.job:
@ -213,21 +211,32 @@ class WorkflowDAG(SimpleDAG):
for node in self.sort_nodes_topological():
obj = node['node_object']
if obj.do_not_run is False and not obj.job and node not in root_nodes:
if obj.do_not_run is False and not obj.job and node not in root_nodes and not obj.all_parents_must_converge:
parent_nodes = [p['node_object'] for p in self.get_parents(obj)]
if self._are_all_nodes_dnr_decided(parent_nodes):
if self._should_mark_node_dnr(node, parent_nodes):
obj.do_not_run = True
nodes_marked_do_not_run.append(node)
if not obj.do_not_run and obj.all_parents_must_converge:
if obj.do_not_run is False and obj.all_parents_must_converge:
if self._are_relevant_parents_finished(node):
# if the current node is a convergence node and all the
# parents are finished then check to see if all parents
# met the needed criteria to run the convergence child
# (i.e. parent must fail, parent must succeed)
parent_nodes = [p['node_object'] for p in self.get_parents(obj)]
if any(p.do_not_run for p in parent_nodes) or not all(obj in self.get_children(p, p.job.status)for p in parent_nodes):
if any(p.do_not_run for p in parent_nodes):
obj.do_not_run = True
nodes_marked_do_not_run.append(node)
else:
for p in parent_nodes:
if p.job.status == "successful":
child_nodes = (c['node_object'] for c in self.get_children(p, "success_nodes"))
elif p.job.status == "failure":
child_nodes = (c['node_object'] for c in self.get_children(p, "failure_nodes"))
else:
child_nodes = (c['node_object'] for c in self.get_children(p, "always_nodes"))
if not any(obj == x for x in child_nodes):
obj.do_not_run = True
nodes_marked_do_not_run.append(node)
return [n['node_object'] for n in nodes_marked_do_not_run]