def workflow_execution_parcial(self):
topological_sort = self.get_topological_sorted_tasks()
for node_obj in topological_sort:
# print self.workflow_graph.node[node]
print (nx.ancestors(self.graph, node_obj),
self.graph.predecessors(node_obj),
node_obj,
self.graph.node[node_obj]['in_degree_required'],
self.graph.node[node_obj]['in_degree'],
self.graph.node[node_obj]['out_degree_required'],
self.graph.node[node_obj]['out_degree']
)
return True
# only to debug
评论列表
文章目录