added exceptions

Author: Andrei Neagu

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

@@ -20,6 +20,9 @@
     CannotCancelWhileWaitingForManualInterventionError,
     InitialOperationContextKeyNotAllowedError,
     KeyNotFoundInHashError,
+    StepNameNotInCurrentGroupError,
+    StepNotInErrorStateError,
+    StepNotWaitingForManualInterventionError,
     UnexpectedStepHandlingError,
 )
 from ._models import (
@@ -348,8 +351,11 @@ async def restart_operation_step_in_error(
         if step_name not in {
             step.get_step_name() for step in step_group.get_step_subgroup_to_run()
         }:
-            msg = f"step_name='{step_name}' not in current step_group_name='{step_group_name}' of operation_name='{operation_name}'"
-            raise ValueError(msg)
+            raise StepNameNotInCurrentGroupError(
+                step_name=step_name,
+                step_group_name=step_group_name,
+                operation_name=operation_name,
+            )
 
         step_proxy = StepStoreProxy(
             store=self._store,
@@ -363,8 +369,7 @@ async def restart_operation_step_in_error(
         try:
             await step_proxy.get("error_traceback")
         except KeyNotFoundInHashError as exc:
-            msg = f"Step '{step_name}' is not in error state and cannot be restarted"
-            raise ValueError(msg) from exc
+            raise StepNotInErrorStateError(step_name=step_name) from exc
 
         if in_manual_intervention:
             requires_manual_intervention: bool = False
@@ -374,8 +379,7 @@ async def restart_operation_step_in_error(
                 )
 
             if requires_manual_intervention is False:
-                msg = f"Step '{step_name}' is not waiting for manual intervention"
-                raise ValueError(msg)
+                raise StepNotWaitingForManualInterventionError(step_name=step_name)
 
             await step_proxy.delete("error_traceback", "requires_manual_intervention")
         else:

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

@@ -52,3 +52,19 @@ class CannotCancelWhileWaitingForManualInterventionError(BaseGenericSchedulerErr
     msg_template: str = (
         "Cannot cancel schedule_id='{schedule_id}' while one or more steps are waiting for manual intervention."
     )
+
+
+class StepNameNotInCurrentGroupError(BaseGenericSchedulerError):
+    msg_template: str = (
+        "step_name='{step_name}' not in current step_group_name='{step_group_name}' of operation_name='{operation_name}'"
+    )
+
+
+class StepNotInErrorStateError(BaseGenericSchedulerError):
+    msg_template: str = (
+        "step_name='{step_name}' is not in an error state and cannot be restarted"
+    )
+
+
+class StepNotWaitingForManualInterventionError(BaseGenericSchedulerError):
+    msg_template: str = "step_name='{step_name}' is not waiting for manual intervention"