moved

Author: Andrei Neagu

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

@@ -268,11 +268,6 @@ async def _safe_event(self, schedule_id: ScheduleId) -> AsyncIterator[None]:
                 message=log_kwargs["msg"],
             )
 
-    async def safe_on_schedule_event(self, schedule_id: ScheduleId) -> None:
-        # NOTE: do not call this directly, you are doing something wrong
-        async with self._safe_event(schedule_id):
-            await self._on_schedule_event(schedule_id)
-
     async def cancel_schedule(self, schedule_id: ScheduleId) -> None:
         """
         Cancels and runs destruction of the operation
@@ -418,6 +413,11 @@ async def restart_operation_step_in_error(
             expected_steps_count=len(step_group),
         )
 
+    async def safe_on_schedule_event(self, schedule_id: ScheduleId) -> None:
+        # NOTE: do not call this directly, you are doing something wrong
+        async with self._safe_event(schedule_id):
+            await self._on_schedule_event(schedule_id)
+
     async def _on_schedule_event(self, schedule_id: ScheduleId) -> None:
         schedule_data_proxy = ScheduleDataStoreProxy(
             store=self._store, schedule_id=schedule_id