typos

Author: Andrei Neagu

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

@@ -1,11 +1,11 @@
 from ._api import (
     cancel_operation,
     restart_operation_stuck_in_error_during_revert,
-    restart_operation_sutck_in_manual_intervention_during_create,
+    restart_operation_stuck_in_manual_intervention_during_create,
     start_operation,
 )
 from ._deferred_runner import (
-    get_opration_context_proxy,
+    get_operation_context_proxy,
     get_step_group_proxy,
     get_step_store_proxy,
 )
@@ -29,7 +29,7 @@
     "BaseStep",
     "cancel_operation",
     "get_generic_scheduler_lifespans",
-    "get_opration_context_proxy",
+    "get_operation_context_proxy",
     "get_step_group_proxy",
     "get_step_store_proxy",
     "Operation",
@@ -39,8 +39,8 @@
     "ParallelStepGroup",
     "ProvidedOperationContext",
     "RequiredOperationContext",
-    "restart_operation_sutck_in_manual_intervention_during_create",
     "restart_operation_stuck_in_error_during_revert",
+    "restart_operation_stuck_in_manual_intervention_during_create",
     "ScheduleId",
     "SingleStepGroup",
     "start_operation",

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

@@ -25,7 +25,7 @@ async def cancel_operation(app: FastAPI, schedule_id: ScheduleId) -> None:
     await get_core(app).cancel_operation(schedule_id)
 
 
-async def restart_operation_sutck_in_manual_intervention_during_create(
+async def restart_operation_stuck_in_manual_intervention_during_create(
     app: FastAPI, schedule_id: ScheduleId, step_name: StepName
 ) -> None:
     """

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

@@ -65,7 +65,7 @@ def get_step_group_proxy(context: DeferredContext) -> StepGroupProxy:
     )
 
 
-def get_opration_context_proxy(context: DeferredContext) -> OperationContextProxy:
+def get_operation_context_proxy(context: DeferredContext) -> OperationContextProxy:
     app: FastAPI = context["app"]
     schedule_id: ScheduleId = context["schedule_id"]
     operation_name: OperationName = context["operation_name"]
@@ -175,10 +175,10 @@ async def run(cls, context: DeferredContext) -> None:
 
         step = _get_step(context)
 
-        opration_context_proxy = get_opration_context_proxy(context)
+        operation_context_proxy = get_operation_context_proxy(context)
 
         if is_creating:
-            required_context = await opration_context_proxy.get_required_context(
+            required_context = await operation_context_proxy.get_required_context(
                 *step.get_create_requires_context_keys()
             )
             _raise_if_any_context_value_is_none(required_context)
@@ -191,7 +191,7 @@ async def run(cls, context: DeferredContext) -> None:
                 provided_operation_context, create_provides_keys
             )
         else:
-            required_context = await opration_context_proxy.get_required_context(
+            required_context = await operation_context_proxy.get_required_context(
                 *step.get_revert_requires_context_keys()
             )
             _raise_if_any_context_value_is_none(required_context)
@@ -204,7 +204,7 @@ async def run(cls, context: DeferredContext) -> None:
                 provided_operation_context, revert_provides_keys
             )
 
-        await opration_context_proxy.set_provided_context(provided_operation_context)
+        await operation_context_proxy.set_provided_context(provided_operation_context)
 
     @classmethod
     async def on_result(cls, result: None, context: DeferredContext) -> None:

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

@@ -60,7 +60,7 @@ def get_create_provides_context_keys(cls) -> set[str]:
     async def get_create_retries(cls, context: DeferredContext) -> int:
         """
         [optional] amount of retires in case of creation
-        HINT: you can use `get_opration_context_proxy()`, `get_step_group_proxy(context)`
+        HINT: you can use `get_operation_context_proxy()`, `get_step_group_proxy(context)`
             and `get_step_store_proxy(context)` to implement custom retry strategy
         """
         assert context  # nosec
@@ -72,7 +72,7 @@ async def get_create_wait_between_attempts(
     ) -> timedelta:
         """
         [optional] wait time between retires case of creation
-        HINT: you can use `get_opration_context_proxy()`, `get_step_group_proxy(context)`
+        HINT: you can use `get_operation_context_proxy()`, `get_step_group_proxy(context)`
             and `get_step_store_proxy(context)` to implement custom retry strategy
         """
         assert context  # nosec
@@ -120,7 +120,7 @@ def get_revert_provides_context_keys(cls) -> set[str]:
     async def get_revert_retries(cls, context: DeferredContext) -> int:
         """
         [optional] amount of retires in case of failure
-        HINT: you can use `get_opration_context_proxy()`, `get_step_group_proxy(context)`
+        HINT: you can use `get_operation_context_proxy()`, `get_step_group_proxy(context)`
             and `get_step_store_proxy(context)` to implement custom retry strategy
         """
         assert context  # nosec
@@ -132,7 +132,7 @@ async def get_revert_wait_between_attempts(
     ) -> timedelta:
         """
         [optional] timeout between retires in case of failure
-        HINT: you can use `get_opration_context_proxy()`, `get_step_group_proxy(context)`
+        HINT: you can use `get_operation_context_proxy()`, `get_step_group_proxy(context)`
             and `get_step_store_proxy(context)` to implement custom retry strategy
         """
         assert context  # nosec

services/dynamic-scheduler/tests/unit/services/generic_scheduler/conftest.py

@@ -12,11 +12,11 @@
 def register_operation() -> Iterable[Callable[[OperationName, Operation], None]]:
     to_unregister: list[OperationName] = []
 
-    def _(opration_name: OperationName, operation: Operation) -> None:
-        OperationRegistry.register(opration_name, operation)
-        to_unregister.append(opration_name)
+    def _(operation_name: OperationName, operation: Operation) -> None:
+        OperationRegistry.register(operation_name, operation)
+        to_unregister.append(operation_name)
 
     yield _
 
-    for opration_name in to_unregister:
-        OperationRegistry.unregister(opration_name)
+    for operation_name in to_unregister:
+        OperationRegistry.unregister(operation_name)

services/dynamic-scheduler/tests/unit/services/generic_scheduler/test__core.py

@@ -31,7 +31,7 @@
     SingleStepGroup,
     cancel_operation,
     restart_operation_stuck_in_error_during_revert,
-    restart_operation_sutck_in_manual_intervention_during_create,
+    restart_operation_stuck_in_manual_intervention_during_create,
     start_operation,
 )
 from simcore_service_dynamic_scheduler.services.generic_scheduler._core import get_core
@@ -1084,7 +1084,7 @@ async def test_wait_for_manual_intervention(
     _GlobalStepIssueTracker.set_issue_solved()
     await limited_gather(
         *(
-            restart_operation_sutck_in_manual_intervention_during_create(
+            restart_operation_stuck_in_manual_intervention_during_create(
                 selected_app, schedule_id, step.get_step_name()
             )
             for step in steps_to_restart

services/dynamic-scheduler/tests/unit/services/generic_scheduler/utils.py

@@ -73,7 +73,7 @@ def _assert_order_random(
         steps_names.remove(step_name)
 
 
-def _asseert_expected_order(
+def _assert_expected_order(
     steps_call_order: list[tuple[str, str]],
     expected_order: list[BaseExpectedStepOrder],
     *,
@@ -119,7 +119,7 @@ async def ensure_expected_order(
     async for attempt in AsyncRetrying(**_RETRY_PARAMS):
         with attempt:
             await asyncio.sleep(0)  # wait for envet to trigger
-            _asseert_expected_order(
+            _assert_expected_order(
                 detected_calls,
                 expected_order,
                 use_only_first_entries=use_only_first_entries,