remove task routing

gso/__init__.py

@@ -23,6 +23,12 @@ from gso.settings import load_oss_params
 SCALAR_OVERRIDES.update(GSO_SCALAR_OVERRIDES)
 
 
+def gso_initialise_celery(celery: Celery) -> None:
+    """Initialise the :term:`Celery` app."""
+    initialise_celery(celery)
+    celery.conf.task_routes = {}
+
+
 def init_gso_app() -> OrchestratorCore:
     """Initialise the :term:`GSO` app."""
     app = OrchestratorCore(base_settings=app_settings)
@@ -43,7 +49,7 @@ def init_gso_app() -> OrchestratorCore:
         celery.conf.update(
             result_expires=config.CELERY.result_expires,
         )
-        initialise_celery(celery)
+        gso_initialise_celery(celery)
 
     return app
 

gso/worker.py

@@ -10,14 +10,13 @@ from orchestrator import app_settings
 from orchestrator.db import init_database
 from orchestrator.domain import SUBSCRIPTION_MODEL_REGISTRY
 from orchestrator.log_config import LOGGER_OVERRIDES, logger_config
-from orchestrator.services.tasks import initialise_celery
 from orchestrator.types import BroadcastFunc
 from orchestrator.websocket import broadcast_process_update_to_websocket, init_websocket_manager
 from orchestrator.websocket.websocket_manager import WebSocketManager
 from orchestrator.workflows import ALL_WORKFLOWS
 from structlog import get_logger
 
-from gso import init_worker_app
+from gso import gso_initialise_celery, init_worker_app
 from gso.settings import load_oss_params
 
 logger = get_logger(__name__)
@@ -104,7 +103,7 @@ celery.conf.update(
     redbeat_redis_url=settings.CELERY.broker_url,
 )
 
-initialise_celery(celery)
+gso_initialise_celery(celery)
 
 
 @worker_shutting_down.connect  # type: ignore[misc]