File tree Expand file tree Collapse file tree 1 file changed +5
-0
lines changed
services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/services/generic_scheduler Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -312,6 +312,7 @@ async def _on_schedule_event(self, schedule_id: ScheduleId) -> None:
312312 # 3) all steps are in a final state, process them
313313 _logger .debug ("steps_statuses=%s in final state in operation" , steps_statuses )
314314
315+ # REPEATING
315316 if step_group .repeat_steps is True and is_creating :
316317 # 3A1) if any of the repeating steps was cancelled -> move to revert
317318 # 3A2) otherwise restart all steps in the group
@@ -323,6 +324,8 @@ async def _on_schedule_event(self, schedule_id: ScheduleId) -> None:
323324 step_group ,
324325 group_step_proxies ,
325326 )
327+
328+ # CREATING
326329 elif is_creating :
327330 # 3B1) if all steps in group in SUUCESS
328331 # - 3B1a) move to next group
@@ -338,6 +341,8 @@ async def _on_schedule_event(self, schedule_id: ScheduleId) -> None:
338341 step_group ,
339342 operation ,
340343 )
344+
345+ # REVERTING
341346 else :
342347 # 3C1) if all steps in gorup in SUUCESS
343348 # - 3C1a) reached the end of the REVERT operation, remove all created data
You can’t perform that action at this time.
0 commit comments