Skip to content
Snippets Groups Projects

add celery as EXECUTOR

Merged Mohammad Torkashvand requested to merge feature/add-celery-executor into develop
All threads resolved!
2 files
+ 9
4
Compare changes
  • Side-by-side
  • Inline
Files
2
+ 7
1
@@ -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
Loading