From 4d9925f5a702a557dccac7b19bb41004d60e8b75 Mon Sep 17 00:00:00 2001 From: Joshua Harlow Date: Thu, 10 Dec 2015 15:36:39 -0800 Subject: [PATCH] Add useful/helpful comment to retry scheduler This is hopefully useful to understand why this happens in this order. Change-Id: I8ff63417489a8d4bada12acc91dbc6bca69df2ba --- taskflow/engines/action_engine/scheduler.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/taskflow/engines/action_engine/scheduler.py b/taskflow/engines/action_engine/scheduler.py index 5fdc19957..1f6785baa 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: