refactor

Author: Andrei Neagu

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

@@ -34,18 +34,25 @@
     Store,
 )
 
-PARALLEL_STATUS_REQUESTS: Final[NonNegativeInt] = 5
-
 _logger = logging.getLogger(__name__)
 
 
+PARALLEL_STATUS_REQUESTS: Final[NonNegativeInt] = 5
+
+
 _IN_PROGRESS_STATUSES: Final[set[StepStatus]] = {
     StepStatus.SCHEDULED,
     StepStatus.CREATED,
     StepStatus.RUNNING,
 }
 
 
+def is_operation_in_progress_status(
+    steps_statuses: dict[StepName, StepStatus],
+) -> bool:
+    return any(status in _IN_PROGRESS_STATUSES for status in steps_statuses.values())
+
+
 async def _get_step_status(step_proxy: StepStoreProxy) -> tuple[StepName, StepStatus]:
     try:
         status = await step_proxy.get("status")
@@ -65,12 +72,6 @@ async def get_steps_statuses(
     return dict(result)
 
 
-def is_operation_in_progress_status(
-    steps_statuses: dict[StepName, StepStatus],
-) -> bool:
-    return any(status in _IN_PROGRESS_STATUSES for status in steps_statuses.values())
-
-
 async def start_and_mark_as_started(
     step_proxy: StepStoreProxy,
     *,