add celery as EXECUTOR

gso/__init__.py

@@ -4,9 +4,12 @@ import os
 
 import sentry_sdk
 import typer
+from celery import Celery
 from orchestrator import OrchestratorCore, app_settings
 from orchestrator.cli.main import app as cli_app
 from orchestrator.graphql import SCALAR_OVERRIDES
+from orchestrator.services.tasks import initialise_celery
+from orchestrator.settings import ExecutorType
 
 # noinspection PyUnresolvedReferences
 import gso.products
@@ -28,6 +31,20 @@ def init_gso_app() -> OrchestratorCore:
     app.register_graphql_authorization(graphql_opa_instance)
     app.register_graphql()
     app.include_router(api_router, prefix="/api")
+
+    if app_settings.EXECUTOR == ExecutorType.WORKER:
+        config = load_oss_params()
+        celery = Celery(
+            "geant-service-orchestrator",
+            broker=config.CELERY.broker_url,
+            backend=config.CELERY.result_backend,
+            include=["orchestrator.services.tasks"],
+        )
+        celery.conf.update(
+            result_expires=config.CELERY.result_expires,
+        )
+        initialise_celery(celery)
+
     return app