From 125d86b9a1aef639b355d3c3bf787d767205afde Mon Sep 17 00:00:00 2001
From: Mohammad Torkashvand <mohammad.torkashvand@geant.org>
Date: Tue, 8 Oct 2024 12:36:17 +0200
Subject: [PATCH] remove unnceccessary OrchestratorApp in worker mode
---
gso/__init__.py | 5 -----
gso/worker.py | 4 +---
2 files changed, 1 insertion(+), 8 deletions(-)
diff --git a/gso/__init__.py b/gso/__init__.py
index 27e95e86..478efc94 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 29f46280..c2e825cc 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()
--
GitLab