diff options
| author | Jenkins <jenkins@review.openstack.org> | 2016-01-20 12:39:57 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2016-01-20 12:39:58 +0000 |
| commit | 04611f57231f8f7cd263023de037f126caa9099c (patch) | |
| tree | 7ffa4ca6cc1c927d8ac826fb5bf3786d3323b23f | |
| parent | e598409f6963243e519b5b5900dbee1a1e50056d (diff) | |
| parent | 4d9925f5a702a557dccac7b19bb41004d60e8b75 (diff) | |
| download | taskflow-04611f57231f8f7cd263023de037f126caa9099c.tar.gz | |
Merge "Add useful/helpful comment to retry scheduler"
| -rw-r--r-- | taskflow/engines/action_engine/scheduler.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/taskflow/engines/action_engine/scheduler.py b/taskflow/engines/action_engine/scheduler.py index 5fdc199..1f6785b 100644 --- a/taskflow/engines/action_engine/scheduler.py +++ b/taskflow/engines/action_engine/scheduler.py @@ -42,6 +42,9 @@ class RetryScheduler(object): return self._retry_action.schedule_reversion(retry) elif intention == st.RETRY: self._retry_action.change_state(retry, st.RETRYING) + # This will force the subflow to start processing right *after* + # this retry atom executes (since they will be blocked on their + # predecessor getting out of the RETRYING/RUNNING state). self._runtime.retry_subflow(retry) return self._retry_action.schedule_execution(retry) else: |