summaryrefslogtreecommitdiff
path: root/taskflow/tests/utils.py
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2014-03-24 11:10:34 +0000
committerGerrit Code Review <review@openstack.org>2014-03-24 11:10:34 +0000
commit7accd01224ed7b982a599e9fb3f899450e2c28b5 (patch)
tree0e43557b328571f7ff7c99878ab2cbe18d02a1d7 /taskflow/tests/utils.py
parentce12f36e56be95feadeb2fb72ca56411500374bd (diff)
parenta395f3e2c14a1edeb4613ad9b82e53fcb501de3e (diff)
downloadtaskflow-7accd01224ed7b982a599e9fb3f899450e2c28b5.tar.gz
Merge "Drop obsolete test_unordered_flow"
Diffstat (limited to 'taskflow/tests/utils.py')
-rw-r--r--taskflow/tests/utils.py20
1 files changed, 0 insertions, 20 deletions
diff --git a/taskflow/tests/utils.py b/taskflow/tests/utils.py
index 8fcf935..64147cf 100644
--- a/taskflow/tests/utils.py
+++ b/taskflow/tests/utils.py
@@ -44,26 +44,6 @@ def wrap_all_failures():
raise exceptions.WrappedFailure([misc.Failure()])
-def make_reverting_task(token, blowup=False):
-
- def do_revert(context, *args, **kwargs):
- context[token] = 'reverted'
-
- if blowup:
-
- def blow_up(context, *args, **kwargs):
- raise RuntimeError("I blew up")
-
- return task.FunctorTask(blow_up, name='blowup_%s' % token)
- else:
-
- def do_apply(context, *args, **kwargs):
- context[token] = 'passed'
-
- return task.FunctorTask(do_apply, revert=do_revert,
- name='do_apply_%s' % token)
-
-
class DummyTask(task.Task):
def execute(self, context, *args, **kwargs):