summaryrefslogtreecommitdiff
path: root/taskflow/engines/action_engine/engine.py
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2015-07-17 16:10:26 +0000
committerGerrit Code Review <review@openstack.org>2015-07-17 16:10:26 +0000
commitfd24d545fa6eda5dbf76a0910a53147fb7f7999f (patch)
tree31ba1976cedc7a2d9d6d667daccf44df4f7528bd /taskflow/engines/action_engine/engine.py
parent78ac726b0df7a784bc6fdf22c219a25cadc0e679 (diff)
parent109b5984b1c62369e17aa6b007321958cf70dc57 (diff)
downloadtaskflow-fd24d545fa6eda5dbf76a0910a53147fb7f7999f.tar.gz
Merge "Just make the compiler object at __init__ time"
Diffstat (limited to 'taskflow/engines/action_engine/engine.py')
-rw-r--r--taskflow/engines/action_engine/engine.py6
1 files changed, 1 insertions, 5 deletions
diff --git a/taskflow/engines/action_engine/engine.py b/taskflow/engines/action_engine/engine.py
index 21bdb27..6d9ee26 100644
--- a/taskflow/engines/action_engine/engine.py
+++ b/taskflow/engines/action_engine/engine.py
@@ -65,7 +65,6 @@ class ActionEngine(base.Engine):
valid states in the states module to learn more about what other states
the tasks and flow being ran can go through.
"""
- _compiler_factory = compiler.PatternCompiler
NO_RERAISING_STATES = frozenset([states.SUSPENDED, states.SUCCESS])
"""
@@ -79,6 +78,7 @@ class ActionEngine(base.Engine):
self._runtime = None
self._compiled = False
self._compilation = None
+ self._compiler = compiler.PatternCompiler(flow)
self._lock = threading.RLock()
self._state_lock = threading.RLock()
self._storage_ensured = False
@@ -286,10 +286,6 @@ class ActionEngine(base.Engine):
self._runtime.reset_all()
self._change_state(states.PENDING)
- @misc.cachedproperty
- def _compiler(self):
- return self._compiler_factory(self._flow)
-
@fasteners.locked
def compile(self):
if self._compiled: