🎨Computational backend: Automatically stop a running job if no logs are detected for 1h

packages/dask-task-models-library/src/dask_task_models_library/container_tasks/errors.py

@@ -3,24 +3,34 @@
 from common_library.errors_classes import OsparcErrorMixin
 
 
-class TaskValueError(OsparcErrorMixin, ValueError): ...
-
-
-class TaskCancelledError(OsparcErrorMixin, RuntimeError):
-    msg_template = "The task was cancelled"
+class ContainerTaskError(OsparcErrorMixin, RuntimeError):
+    msg_template = (
+        "The service {service_key}:{service_version}"
+        " running in container {container_id} encountered an unexpected error: {error_message}."
+    )
 
 
-class ServiceRuntimeError(OsparcErrorMixin, RuntimeError):
+class ServiceRuntimeError(ContainerTaskError):
     msg_template = (
         "The service {service_key}:{service_version}"
         " running in container {container_id} failed with code"
         " {exit_code}. Last logs:\n{service_logs}"
     )
 
 
-class ServiceInputsUseFileToKeyMapButReceivesZipDataError(
-    OsparcErrorMixin, RuntimeError
-):
+class ServiceTimeoutLoggingError(ContainerTaskError):
+    msg_template = (
+        "The service {service_key}:{service_version}"
+        " running in container {container_id} was detected as hanging and forcefully terminated by the platform. "
+        "This happened because it exceeded the maximum allowed time of {timeout_timedelta} without producing any logs."
+    )
+
+
+class TaskCancelledError(ContainerTaskError):
+    msg_template = "The task was cancelled"
+
+
+class ServiceInputsUseFileToKeyMapButReceivesZipDataError(ContainerTaskError):
     msg_template = (
         "The service {service_key}:{service_version} {input} uses a file-to-key {file_to_key_map} map but receives zip data instead. "
         "TIP: either pass a single file or zip file and remove the file-to-key map parameter."