diff --git a/taskflow/engines/action_engine/engine.py b/taskflow/engines/action_engine/engine.py index 309e1a32..cc6b1ac4 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...