fix tests

Author: bisgaard-itis

packages/models-library/src/models_library/api_schemas_webserver/storage.py

@@ -65,10 +65,6 @@ def from_job_id(cls, app: web.Application, job_id: str) -> "AsyncJobLinks":
         )
 
 
-class StorageAsyncJobId(InputSchema):
-    job_id: AsyncJobId
-
-
 class StorageAsyncJobGet(OutputSchema):
     job_id: AsyncJobId
     links: AsyncJobLinks

services/web/server/src/simcore_service_webserver/storage/_rest.py

@@ -9,7 +9,10 @@
 from urllib.parse import quote, unquote
 
 from aiohttp import ClientTimeout, web
-from models_library.api_schemas_rpc_async_jobs.async_jobs import AsyncJobNameData
+from models_library.api_schemas_rpc_async_jobs.async_jobs import (
+    AsyncJobId,
+    AsyncJobNameData,
+)
 from models_library.api_schemas_storage import STORAGE_RPC_NAMESPACE
 from models_library.api_schemas_storage.storage_schemas import (
     FileUploadCompleteResponse,
@@ -20,7 +23,6 @@
 from models_library.api_schemas_webserver.storage import (
     DataExportPost,
     StorageAsyncJobGet,
-    StorageAsyncJobId,
     StorageAsyncJobResult,
     StorageAsyncJobStatus,
 )
@@ -469,6 +471,10 @@ async def get_async_jobs(request: web.Request) -> web.Response:
     )
 
 
+class _StorageAsyncJobId(BaseModel):
+    job_id: AsyncJobId
+
+
 @routes.get(
     _storage_prefix + "/async-jobs/{job_id}/status",
     name="get_async_job_status",
@@ -480,7 +486,7 @@ async def get_async_job_status(request: web.Request) -> web.Response:
     _req_ctx = RequestContext.model_validate(request)
     rabbitmq_rpc_client = get_rabbitmq_rpc_client(request.app)
 
-    async_job_get = parse_request_path_parameters_as(StorageAsyncJobId, request)
+    async_job_get = parse_request_path_parameters_as(_StorageAsyncJobId, request)
     async_job_rpc_status = await get_status(
         rabbitmq_rpc_client=rabbitmq_rpc_client,
         rpc_namespace=STORAGE_RPC_NAMESPACE,
@@ -508,7 +514,7 @@ async def abort_async_job(request: web.Request) -> web.Response:
     _req_ctx = RequestContext.model_validate(request)
 
     rabbitmq_rpc_client = get_rabbitmq_rpc_client(request.app)
-    async_job_get = parse_request_path_parameters_as(StorageAsyncJobId, request)
+    async_job_get = parse_request_path_parameters_as(_StorageAsyncJobId, request)
     async_job_rpc_abort = await abort(
         rabbitmq_rpc_client=rabbitmq_rpc_client,
         rpc_namespace=STORAGE_RPC_NAMESPACE,
@@ -537,7 +543,7 @@ async def get_async_job_result(request: web.Request) -> web.Response:
     _req_ctx = RequestContext.model_validate(request)
 
     rabbitmq_rpc_client = get_rabbitmq_rpc_client(request.app)
-    async_job_get = parse_request_path_parameters_as(StorageAsyncJobId, request)
+    async_job_get = parse_request_path_parameters_as(_StorageAsyncJobId, request)
     async_job_rpc_result = await get_result(
         rabbitmq_rpc_client=rabbitmq_rpc_client,
         rpc_namespace=STORAGE_RPC_NAMESPACE,