diff options
| author | Joshua Harlow <harlowja@yahoo-inc.com> | 2014-04-09 15:28:43 -0700 |
|---|---|---|
| committer | Joshua Harlow <harlowja@yahoo-inc.com> | 2014-05-07 14:41:17 -0700 |
| commit | 53dcbd4d97ff1b83c4db030571bfa88750dcb06a (patch) | |
| tree | 5d3e89aedea3b11077a0c7235673c271275e9fe2 /taskflow/tests/utils.py | |
| parent | ee1e96d87d385baf3f583cabea94997b50130985 (diff) | |
| download | taskflow-53dcbd4d97ff1b83c4db030571bfa88750dcb06a.tar.gz | |
Implement run iterations
Instead of blocking the caller when they call run()
allow there to be a new api run_iter() that will yield
back the engine state transitions while running. This
allows for a engine user to do alternate work while an
engine is running (and come back to yield on there own
time).
Implements blueprint iterable-execution
Change-Id: Ibb48c6c5618c97c59a6ab170dab5233ed47e5554
Diffstat (limited to 'taskflow/tests/utils.py')
| -rw-r--r-- | taskflow/tests/utils.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/taskflow/tests/utils.py b/taskflow/tests/utils.py index 20fc375..d879321 100644 --- a/taskflow/tests/utils.py +++ b/taskflow/tests/utils.py @@ -258,7 +258,7 @@ class EngineTestBase(object): conn.clear_all() super(EngineTestBase, self).tearDown() - def _make_engine(self, flow, flow_detail=None): + def _make_engine(self, flow, **kwargs): raise NotImplementedError() |