fix timedelta

Author: giancarloromeo

packages/service-library/src/servicelib/fastapi/long_running_tasks/_context_manager.py

@@ -118,7 +118,7 @@ async def _wait_task_completion() -> None:
         logger.debug("%s, %s", f"{task_id=}", f"{result=}")
 
         yield result
-    except asyncio.TimeoutError as e:
+    except TimeoutError as e:
         await client.cancel_and_delete_task(task_id)
         raise TaskClientTimeoutError(
             task_id=task_id,

services/director-v2/src/simcore_service_director_v2/modules/dynamic_sidecar/api_client/_public.py

@@ -358,7 +358,7 @@ async def restore_service_state(self, dynamic_sidecar_endpoint: AnyHttpUrl) -> i
         result: Any | None = await self._await_for_result(
             task_id,
             dynamic_sidecar_endpoint,
-            self._dynamic_services_scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT,
+            self._dynamic_services_scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT.total_seconds(),
             _debug_progress_callback,
         )
         assert isinstance(result, int)  # nosec
@@ -392,7 +392,7 @@ async def save_service_state(
         result: Any | None = await self._await_for_result(
             task_id,
             dynamic_sidecar_endpoint,
-            self._dynamic_services_scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT,
+            self._dynamic_services_scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT.total_seconds(),
             progress_callback,
         )
         assert isinstance(result, int)  # nosec
@@ -411,7 +411,7 @@ async def pull_service_input_ports(
         transferred_bytes = await self._await_for_result(
             task_id,
             dynamic_sidecar_endpoint,
-            self._dynamic_services_scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT,
+            self._dynamic_services_scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT.total_seconds(),
             _debug_progress_callback,
         )
         return transferred_bytes or 0
@@ -429,7 +429,7 @@ async def pull_service_output_ports(
         result: Any | None = await self._await_for_result(
             task_id,
             dynamic_sidecar_endpoint,
-            self._dynamic_services_scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT,
+            self._dynamic_services_scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT.total_seconds(),
             _debug_progress_callback,
         )
         assert isinstance(result, int)  # nosec
@@ -448,7 +448,7 @@ async def push_service_output_ports(
         await self._await_for_result(
             task_id,
             dynamic_sidecar_endpoint,
-            self._dynamic_services_scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT,
+            self._dynamic_services_scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT.total_seconds(),
             progress_callback,
         )
 
@@ -495,7 +495,9 @@ async def get_service_activity(
             dynamic_sidecar_endpoint
         )
         decoded_response = response.json()
-        return ActivityInfo.model_validate(decoded_response) if decoded_response else None
+        return (
+            ActivityInfo.model_validate(decoded_response) if decoded_response else None
+        )
 
     async def free_reserved_disk_space(
         self, dynamic_sidecar_endpoint: AnyHttpUrl

services/director-v2/src/simcore_service_director_v2/modules/dynamic_sidecar/api_client/_thin.py

@@ -35,7 +35,7 @@ def __init__(self, app: FastAPI):
         # timeouts
         self._health_request_timeout = Timeout(1.0, connect=1.0)
         self._save_restore_timeout = Timeout(
-            scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT,
+            scheduler_settings.DYNAMIC_SIDECAR_API_SAVE_RESTORE_STATE_TIMEOUT.total_seconds(),
             connect=scheduler_settings.DYNAMIC_SIDECAR_API_CONNECT_TIMEOUT,
         )
         self._restart_containers_timeout = Timeout(