diff --git a/taskflow/engines/action_engine/engine.py b/taskflow/engines/action_engine/engine.py index e3f09eb6..21504648 100644 --- a/taskflow/engines/action_engine/engine.py +++ b/taskflow/engines/action_engine/engine.py @@ -98,7 +98,7 @@ class ActionEngine(base.EngineBase): @property def execution_graph(self): self.compile() - return self._analyzer.graph + return self._analyzer.execution_graph @lock_utils.locked def run(self): diff --git a/taskflow/engines/action_engine/graph_analyzer.py b/taskflow/engines/action_engine/graph_analyzer.py index 7e87197e..78ca8596 100644 --- a/taskflow/engines/action_engine/graph_analyzer.py +++ b/taskflow/engines/action_engine/graph_analyzer.py @@ -22,14 +22,17 @@ from taskflow import states as st class GraphAnalyzer(object): - """Analyzes graph to get next nodes for execution or reversion""" + """Analyzes a execution graph to get the next nodes for execution or + reversion by utilizing the graphs nodes and edge relations and comparing + the node state against the states stored in storage. + """ def __init__(self, graph, storage): self._graph = graph self._storage = storage @property - def graph(self): + def execution_graph(self): return self._graph def browse_nodes_for_execute(self, node=None):