Skip to content
Snippets Groups Projects
Commit 125d86b9 authored by Mohammad Torkashvand's avatar Mohammad Torkashvand
Browse files

remove unnceccessary OrchestratorApp in worker mode

parent 47eb35e8
No related branches found
No related tags found
1 merge request!282remove unnecessary OrchestratorApp in worker mode
Pipeline #89561 passed
......@@ -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
......
......@@ -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()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment