fix: remove rpc routes

Author: giancarloromeo

services/storage/src/simcore_service_storage/api/_worker_tasks/tasks.py

@@ -2,16 +2,10 @@
 
 from celery import Celery  # type: ignore[import-untyped]
 from celery_library.task import register_task
-from celery_library.types import register_celery_types, register_pydantic_types
+from celery_library.types import register_celery_types
 from models_library.api_schemas_storage.export_data_async_jobs import AccessRightError
-from models_library.api_schemas_storage.storage_schemas import (
-    FileUploadCompletionBody,
-    FoldersBody,
-    PresignedLink,
-)
 from servicelib.logging_utils import log_context
 
-from ...models import FileMetaData
 from ._files import complete_upload_file
 from ._paths import compute_path_size, delete_paths
 from ._simcore_s3 import (
@@ -26,11 +20,8 @@
 
 def setup_worker_tasks(app: Celery) -> None:
     register_celery_types()
-    register_pydantic_types(
-        FileUploadCompletionBody, FileMetaData, FoldersBody, PresignedLink
-    )
 
-    with log_context(_logger, logging.INFO, msg="worker task registration"):
+    with log_context(_logger, logging.INFO, msg="worker tasks registration"):
         register_task(app, export_data, dont_autoretry_for=(AccessRightError,))
         register_task(
             app, export_data_as_download_link, dont_autoretry_for=(AccessRightError,)

services/storage/src/simcore_service_storage/api/rpc/routes.py

@@ -1,6 +1,5 @@
 import logging
 
-from celery_library.rpc import _async_jobs
 from fastapi import FastAPI
 from models_library.api_schemas_storage import STORAGE_RPC_NAMESPACE
 from servicelib.logging_utils import log_context
@@ -14,7 +13,6 @@
 
 
 ROUTERS: list[RPCRouter] = [
-    _async_jobs.router,
     _paths.router,
     _simcore_s3.router,
 ]

services/storage/src/simcore_service_storage/modules/celery/__init__.py

@@ -3,20 +3,13 @@
 from celery_library.backends.redis import RedisTaskInfoStore
 from celery_library.common import create_app
 from celery_library.task_manager import CeleryTaskManager
-from celery_library.types import register_celery_types, register_pydantic_types
+from celery_library.types import register_celery_types
 from fastapi import FastAPI
-from models_library.api_schemas_storage.search_async_jobs import SearchResult
-from models_library.api_schemas_storage.storage_schemas import (
-    FileUploadCompletionBody,
-    FoldersBody,
-)
 from servicelib.logging_utils import log_context
 from servicelib.redis import RedisClientSDK
 from settings_library.celery import CelerySettings
 from settings_library.redis import RedisDatabase
 
-from ...models import FileMetaData
-
 _logger = logging.getLogger(__name__)
 
 
@@ -39,7 +32,6 @@ async def on_startup() -> None:
             )
 
             register_celery_types()
-            register_pydantic_types(FileUploadCompletionBody, FileMetaData, FoldersBody, SearchResult)
 
     async def on_shutdown() -> None:
         with log_context(_logger, logging.INFO, "Shutting down Celery"):

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

@@ -76,7 +76,7 @@ async def get_async_jobs(request: web.Request) -> web.Response:
             get_job_filter(
                 user_id=_req_ctx.user_id,
                 product_name=_req_ctx.product_name,
-            )
+            ).model_dump(),
         )
     )
 
@@ -119,7 +119,7 @@ async def get_async_job_status(request: web.Request) -> web.Response:
             get_job_filter(
                 user_id=_req_ctx.user_id,
                 product_name=_req_ctx.product_name,
-            )
+            ).model_dump(),
         ),
         task_uuid=path_params.task_id,
     )
@@ -153,7 +153,7 @@ async def cancel_async_job(request: web.Request) -> web.Response:
             get_job_filter(
                 user_id=_req_ctx.user_id,
                 product_name=_req_ctx.product_name,
-            )
+            ).model_dump(),
         ),
         task_uuid=path_params.task_id,
     )
@@ -177,7 +177,7 @@ async def get_async_job_result(request: web.Request) -> web.Response:
             get_job_filter(
                 user_id=_req_ctx.user_id,
                 product_name=_req_ctx.product_name,
-            )
+            ).model_dump(),
         ),
         task_uuid=path_params.task_id,
     )
@@ -206,7 +206,7 @@ async def event_generator():
                 get_job_filter(
                     user_id=_req_ctx.user_id,
                     product_name=_req_ctx.product_name,
-                )
+                ).model_dump(),
             ),
             task_uuid=path_params.task_id,
             last_id=header_params.last_event_id,