From 5dac1dd121656ebea0ffd1a54c55d2db7c5397cf Mon Sep 17 00:00:00 2001 From: Mathieu Virbel Date: Wed, 13 Dec 2023 12:26:03 +0100 Subject: [PATCH] server: fix detection of default celery --- server/reflector/worker/app.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/reflector/worker/app.py b/server/reflector/worker/app.py index 7df0423e..5f1e4e74 100644 --- a/server/reflector/worker/app.py +++ b/server/reflector/worker/app.py @@ -4,7 +4,7 @@ from celery import Celery from reflector.settings import settings logger = structlog.get_logger(__name__) -if celery.current_app is not None: +if celery.current_app.main != "default": logger.info(f"Celery already configured ({celery.current_app})") app = celery.current_app else: