Skip to content

Commit 7330395

Browse files
author
Andrei Neagu
committed
extracted repeating steps function
1 parent 988903e commit 7330395

File tree

1 file changed

+3
-3
lines changed
  • services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/services/generic_scheduler

1 file changed

+3
-3
lines changed

services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/services/generic_scheduler/_core.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -349,8 +349,8 @@ async def _on_schedule_event(self, schedule_id: ScheduleId) -> None:
349349
_logger.debug("Operation completed: steps_statuses=%s", steps_statuses)
350350

351351
# NOTE: at this point all steps are in a final status
352-
if step_group.repeat_steps is True:
353-
await self._continue_as_repeat_steps(
352+
if step_group.repeat_steps is True and is_creating:
353+
await self._continue_as_repeating_steps(
354354
schedule_data_proxy,
355355
schedule_id,
356356
operation_name,
@@ -378,7 +378,7 @@ async def _on_schedule_event(self, schedule_id: ScheduleId) -> None:
378378
step_group,
379379
)
380380

381-
async def _continue_as_repeat_steps(
381+
async def _continue_as_repeating_steps(
382382
self,
383383
schedule_data_proxy: ScheduleDataStoreProxy,
384384
schedule_id: ScheduleId,

0 commit comments

Comments
 (0)