diff options
| author | Joshua Harlow <harlowja@yahoo-inc.com> | 2013-05-28 17:39:20 -0700 |
|---|---|---|
| committer | Joshua Harlow <harlowja@yahoo-inc.com> | 2013-05-28 17:39:20 -0700 |
| commit | f528d4bd8152aff6e27c646e08cde00dd7847a39 (patch) | |
| tree | 04885db4f421b0955f62e081b92676726b5610de /taskflow/patterns | |
| parent | e51a26395578d80c0bc3abb877ae963337cd1e9c (diff) | |
| download | taskflow-f528d4bd8152aff6e27c646e08cde00dd7847a39.tar.gz | |
Ensure we handle functor names and resetting correctly.
Diffstat (limited to 'taskflow/patterns')
| -rw-r--r-- | taskflow/patterns/ordered_flow.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/taskflow/patterns/ordered_flow.py b/taskflow/patterns/ordered_flow.py index 21acb7a..50b6418 100644 --- a/taskflow/patterns/ordered_flow.py +++ b/taskflow/patterns/ordered_flow.py @@ -194,8 +194,12 @@ class Flow(object): self._change_state(context, states.SUCCESS) def reset(self): + # Reset all internal state (except our parent workflows). self._state = states.PENDING self.results = [] + self.task_listeners = [] + self.listeners = [] + self.result_fetcher = None self._accumulator.reset() def interrupt(self): |