celery -> celery_worker

Author: bisgaard-itis

services/api-server/docker/boot_celery_worker.py

@@ -2,7 +2,10 @@
 from celery_library.signals import (
     on_worker_shutdown,
 )
-from simcore_service_api_server.celery.worker_main import get_app, worker_init_wrapper
+from simcore_service_api_server.celery_worker.worker_main import (
+    get_app,
+    worker_init_wrapper,
+)
 
 app = get_app()
 

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

@@ -6,7 +6,7 @@
 from fastapi import FastAPI
 from settings_library.celery import CelerySettings
 
-from ...celery.worker_tasks.tasks import pydantic_types_to_register
+from ...celery_worker.worker_tasks.tasks import pydantic_types_to_register
 
 ASYNC_JOB_CLIENT_NAME: Final[str] = "API_SERVER"
 

services/api-server/src/simcore_service_api_server/api/routes/functions_routes.py

@@ -27,8 +27,10 @@
 
 from ..._service_function_jobs import FunctionJobService
 from ..._service_functions import FunctionService
-from ...celery.worker_tasks.functions_tasks import function_map as map_task
-from ...celery.worker_tasks.functions_tasks import run_function as run_function_task
+from ...celery_worker.worker_tasks.functions_tasks import function_map as map_task
+from ...celery_worker.worker_tasks.functions_tasks import (
+    run_function as run_function_task,
+)
 from ...exceptions.function_errors import FunctionJobCacheNotFoundError
 from ...models.domain.functions import PreRegisteredFunctionJobData
 from ...models.pagination import Page, PaginationParams

services/api-server/src/simcore_service_api_server/celery/__init__.py renamed to services/api-server/src/simcore_service_api_server/celery_worker/__init__.py

@@ -26,7 +26,7 @@
 from pytest_simcore.helpers.monkeypatch_envs import delenvs_from_dict, setenvs_from_dict
 from pytest_simcore.helpers.typing_env import EnvVarsDict
 from servicelib.fastapi.celery.app_server import FastAPIAppServer
-from simcore_service_api_server.celery.worker_main import setup_worker_tasks
+from simcore_service_api_server.celery_worker.worker_main import setup_worker_tasks
 from simcore_service_api_server.core.application import create_app
 from simcore_service_api_server.core.settings import ApplicationSettings
 

services/api-server/src/simcore_service_api_server/celery/worker_main.py renamed to services/api-server/src/simcore_service_api_server/celery_worker/worker_main.py

@@ -58,7 +58,7 @@
     ASYNC_JOB_CLIENT_NAME,
     get_task_manager,
 )
-from simcore_service_api_server.celery.worker_tasks.functions_tasks import (
+from simcore_service_api_server.celery_worker.worker_tasks.functions_tasks import (
     run_function as run_function_task,
 )
 from simcore_service_api_server.exceptions.backend_errors import BaseBackEndError