openstack/deb-python-taskflow
Code Issues Proposed changes

Expose action engine no reraising states constants

Browse Source 
Change-Id: I65746fc7bc27f0b03e416eb6584df18bbc4a3053
This commit is contained in:
Joshua Harlow
2015-05-11 15:06:25 -07:00
parent 4e550ba48c
commit 24a11aa523
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
taskflow/engines/action_engine/engine.py
View File

@@ -66,6 +66,13 @@ class ActionEngine(base.Engine):
"""
_compiler_factory = compiler.PatternCompiler
NO_RERAISING_STATES = frozenset([states.SUSPENDED, states.SUCCESS])
"""
States that if the engine stops in will **not** cause any potential
failures to be reraised. States **not** in this list will cause any
failure/s that were captured (if any) to get reraised.
"""
def __init__(self, flow, flow_detail, backend, options):
super(ActionEngine, self).__init__(flow, flow_detail, backend, options)
self._runtime = None
@@ -178,7 +185,7 @@ class ActionEngine(base.Engine):
ignorable_states = getattr(runner, 'ignorable_states', [])
if last_state and last_state not in ignorable_states:
self._change_state(last_state)
if last_state not in [states.SUSPENDED, states.SUCCESS]:
if last_state not in self.NO_RERAISING_STATES:
failures = self.storage.get_failures()
failure.Failure.reraise_if_any(failures.values())