openstack/deb-python-taskflow
Code Issues Proposed changes

Merge pull request #13 from harlowja/fixed-resume

Browse Source 
Correctly run the tasks after partial resumption.
This commit is contained in:
Joshua Harlow
2013-05-16 23:24:27 -07:00
parent a4f79aa341 208108fc62
commit c107c95584
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
taskflow/patterns/ordered_workflow.py
View File

@@ -111,10 +111,11 @@ class Workflow(object):
self.rollback(context, exc.TaskException(task, self, ex))
self._change_state(context, states.FAILURE)
self._change_state(context, states.RESUMING)
task_order = self.order()
last_task = 0
if result_fetcher:
for (i, task) in enumerate(self.order()):
self._change_state(context, states.RESUMING)
for (i, task) in enumerate(task_order):
(has_result, result) = result_fetcher(self, task)
if not has_result:
break
@@ -136,7 +137,7 @@ class Workflow(object):
self._change_state(context, states.RUNNING)
was_interrupted = False
for task in self.order():
for task in task_order[last_task:]:
if self.state == states.INTERRUPTED:
was_interrupted = True
break