summaryrefslogtreecommitdiff
path: root/taskflow/engines
diff options
context:
space:
mode:
authorJoshua Harlow <harlowja@gmail.com>2016-05-28 21:59:44 -0700
committerJoshua Harlow <harlowja@gmail.com>2016-05-28 21:59:52 -0700
commit0766397b54e66c550047d6b3743907b09fc9ef7f (patch)
tree4535b91ac3dfd56e5dd4094e47a6147d208d5609 /taskflow/engines
parent459b0a2c6a546d190f26de966f247d9e200b9d5c (diff)
downloadtaskflow-0766397b54e66c550047d6b3743907b09fc9ef7f.tar.gz
Use the full 'get_execute_failures' vs the shortname
The usage of the full name is easier to read and easier to understand in the surronding code so prefer to use it. Change-Id: I1c43704ae7dfdba90217ce9a1c60cef8e2ce8632
Diffstat (limited to 'taskflow/engines')
-rw-r--r--taskflow/engines/action_engine/engine.py12
1 files changed, 6 insertions, 6 deletions
diff --git a/taskflow/engines/action_engine/engine.py b/taskflow/engines/action_engine/engine.py
index aea4b1f..1ae16c9 100644
--- a/taskflow/engines/action_engine/engine.py
+++ b/taskflow/engines/action_engine/engine.py
@@ -332,12 +332,12 @@ class ActionEngine(base.Engine):
if new_state not in self.IGNORABLE_STATES:
self._change_state(new_state)
if new_state not in self.NO_RERAISING_STATES:
- failures = self.storage.get_failures()
- more_failures = self.storage.get_revert_failures()
- fails = itertools.chain(
- six.itervalues(failures),
- six.itervalues(more_failures))
- failure.Failure.reraise_if_any(fails)
+ e_failures = self.storage.get_execute_failures()
+ r_failures = self.storage.get_revert_failures()
+ er_failures = itertools.chain(
+ six.itervalues(e_failures),
+ six.itervalues(r_failures))
+ failure.Failure.reraise_if_any(er_failures)
finally:
if w is not None:
w.stop()