@pcrespov decouple setup of celery task manager from dependencies submodule

Author: bisgaard-itis

services/api-server/src/simcore_service_api_server/api/dependencies/celery.py

@@ -1,28 +1,11 @@
 from typing import Final
 
-from celery_library.common import create_app, create_task_manager
 from celery_library.task_manager import CeleryTaskManager
-from celery_library.types import register_celery_types, register_pydantic_types
 from fastapi import FastAPI
-from settings_library.celery import CelerySettings
-
-from ...celery_worker.worker_tasks.tasks import pydantic_types_to_register
 
 ASYNC_JOB_CLIENT_NAME: Final[str] = "API_SERVER"
 
 
-def setup_task_manager(app: FastAPI, celery_settings: CelerySettings) -> None:
-    async def on_startup() -> None:
-        app.state.task_manager = await create_task_manager(
-            create_app(celery_settings), celery_settings
-        )
-
-        register_celery_types()
-        register_pydantic_types(*pydantic_types_to_register)
-
-    app.add_event_handler("startup", on_startup)
-
-
 def get_task_manager(app: FastAPI) -> CeleryTaskManager:
     assert hasattr(app.state, "task_manager")  # nosec
     task_manager = app.state.task_manager

services/api-server/src/simcore_service_api_server/clients/celery_task_manager.py

@@ -0,0 +1,18 @@
+from celery_library.common import create_app, create_task_manager
+from celery_library.types import register_celery_types, register_pydantic_types
+from fastapi import FastAPI
+from settings_library.celery import CelerySettings
+
+from ..celery_worker.worker_tasks.tasks import pydantic_types_to_register
+
+
+def setup_task_manager(app: FastAPI, celery_settings: CelerySettings) -> None:
+    async def on_startup() -> None:
+        app.state.task_manager = await create_task_manager(
+            create_app(celery_settings), celery_settings
+        )
+
+        register_celery_types()
+        register_pydantic_types(*pydantic_types_to_register)
+
+    app.add_event_handler("startup", on_startup)

services/api-server/src/simcore_service_api_server/core/application.py

@@ -13,9 +13,9 @@
 
 from .. import exceptions
 from .._meta import API_VERSION, API_VTAG, APP_NAME
-from ..api.dependencies.celery import setup_task_manager
 from ..api.root import create_router
 from ..api.routes.health import router as health_router
+from ..clients.celery_task_manager import setup_task_manager
 from ..clients.postgres import setup_postgres
 from ..services_http import director_v2, storage, webserver
 from ..services_http.rabbitmq import setup_rabbitmq