server: fix detection of default celery

This commit is contained in:
2023-12-13 12:26:03 +01:00
parent 6585002dfa
commit 5dac1dd121

View File

@@ -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: