diff --git a/gso/__init__.py b/gso/__init__.py index 27e95e86538eda8af3aaee6eb267ebdc514f80b4..478efc94c1cba9cec5745153b8a47890c83feab0 100644 --- a/gso/__init__.py +++ b/gso/__init__.py @@ -54,11 +54,6 @@ def init_gso_app() -> OrchestratorCore: return app -def init_worker_app() -> OrchestratorCore: - """Initialise a :term:`GSO` instance as Celery worker.""" - return OrchestratorCore(base_settings=app_settings) - - def init_cli_app() -> typer.Typer: """Initialise :term:`GSO` as a CLI application.""" from gso.cli import imports, netbox # noqa: PLC0415 diff --git a/gso/worker.py b/gso/worker.py index 29f4628034ea981387c9ae73585715dced339674..c2e825cc8d8b4224acc67ada88c6b3b2721b1dce 100644 --- a/gso/worker.py +++ b/gso/worker.py @@ -16,7 +16,7 @@ from orchestrator.websocket.websocket_manager import WebSocketManager from orchestrator.workflows import ALL_WORKFLOWS from structlog import get_logger -from gso import gso_initialise_celery, init_worker_app +from gso import gso_initialise_celery from gso.settings import load_oss_params logger = get_logger(__name__) @@ -67,8 +67,6 @@ class OrchestratorWorker(Celery): products=len(SUBSCRIPTION_MODEL_REGISTRY.values()), ) - init_worker_app() - def close(self) -> None: """Close Celery worker cleanly.""" super().close()