diff options
Diffstat (limited to 'taskflow/engines/action_engine/compiler.py')
| -rw-r--r-- | taskflow/engines/action_engine/compiler.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/taskflow/engines/action_engine/compiler.py b/taskflow/engines/action_engine/compiler.py index c72506a..2642e53 100644 --- a/taskflow/engines/action_engine/compiler.py +++ b/taskflow/engines/action_engine/compiler.py @@ -18,7 +18,6 @@ import threading import fasteners from oslo_utils import excutils -import six from taskflow import flow from taskflow import logging @@ -65,7 +64,8 @@ class Terminator(object): return self._name def __str__(self): - return "%s[$]" % (self._flow,) + flow_name = ("%s" % self._flow).strip('"') + return '"%s[$]"' % flow_name class Compilation(object): @@ -165,7 +165,7 @@ class FlowCompiler(object): decomposed = dict( (child, self._deep_compiler_func(child, parent=tree_node)[0]) for child in flow) - decomposed_graphs = list(six.itervalues(decomposed)) + decomposed_graphs = list(decomposed.values()) graph = gr.merge_graphs(graph, *decomposed_graphs, overlap_detector=_overlap_occurrence_detector) for u, v, attr_dict in flow.iter_links(): |