rename

Author: Andrei Neagu

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

@@ -154,9 +154,9 @@ async def get_timeout(cls, context: DeferredContext) -> timedelta:
         is_creating = context["is_creating"]
         step = _get_step(context)
         return (
-            await step.get_create_timeout(context)
+            await step.get_create_wait_between_attempts(context)
             if is_creating
-            else await step.get_revert_timeout(context)
+            else await step.get_revert_wait_between_attempts(context)
         )
 
     @classmethod

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

@@ -63,8 +63,10 @@ async def get_create_retries(cls, context: DeferredContext) -> int:
         return _DEFAULT_STEP_RETRIES
 
     @classmethod
-    async def get_create_timeout(cls, context: DeferredContext) -> timedelta:
-        """[optional] timeout between retires case of creation"""
+    async def get_create_wait_between_attempts(
+        cls, context: DeferredContext
+    ) -> timedelta:
+        """[optional] wait time between retires case of creation"""
         assert context  # nosec
         return _DEFAULT_STEP_TIMEOUT
 
@@ -113,7 +115,9 @@ async def get_revert_retries(cls, context: DeferredContext) -> int:
         return _DEFAULT_STEP_RETRIES
 
     @classmethod
-    async def get_revert_timeout(cls, context: DeferredContext) -> timedelta:
+    async def get_revert_wait_between_attempts(
+        cls, context: DeferredContext
+    ) -> timedelta:
         """[optional] timeout between retires in case of failure"""
         assert context  # nosec
         return _DEFAULT_STEP_TIMEOUT

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

@@ -217,7 +217,9 @@ async def get_create_retries(cls, context: DeferredContext) -> int:
         return 10
 
     @classmethod
-    async def get_create_timeout(cls, context: DeferredContext) -> timedelta:
+    async def get_create_wait_between_attempts(
+        cls, context: DeferredContext
+    ) -> timedelta:
         _ = context
         return _STEP_SLEEP_DURATION