diff options
| author | Jenkins <jenkins@review.openstack.org> | 2015-08-01 17:23:30 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2015-08-01 17:23:30 +0000 |
| commit | 8ff212f7bbea5b63d9f188ce7b73c2e999c7286f (patch) | |
| tree | 5a695b966b1b52857eb4238bdddb8e0f4debfa8c /taskflow | |
| parent | 572e7268cf08988b844e9851bcbbc32d19ed408c (diff) | |
| parent | ecab10a6d6a1bdc893c0ad17405f9a7323ce9e1d (diff) | |
| download | taskflow-8ff212f7bbea5b63d9f188ce7b73c2e999c7286f.tar.gz | |
Merge "Use the action engine '_check' helper method"
Diffstat (limited to 'taskflow')
| -rw-r--r-- | taskflow/engines/action_engine/engine.py | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/taskflow/engines/action_engine/engine.py b/taskflow/engines/action_engine/engine.py index 309e1a3..cc6b1ac 100644 --- a/taskflow/engines/action_engine/engine.py +++ b/taskflow/engines/action_engine/engine.py @@ -309,10 +309,7 @@ class ActionEngine(base.Engine): @fasteners.locked def reset(self): - if not self._storage_ensured: - raise exc.InvalidState("Can not reset an engine" - " which has not has its storage" - " populated") + self._check('reset', True, True) # This transitions *all* contained atoms back into the PENDING state # with an intention to EXECUTE (or dies trying to do that) and then # changes the state of the flow to PENDING so that it can then run... |