diff --git a/backend/onyx/background/celery/apps/app_base.py b/backend/onyx/background/celery/apps/app_base.py index 072867453370..22529a66c2b6 100644 --- a/backend/onyx/background/celery/apps/app_base.py +++ b/backend/onyx/background/celery/apps/app_base.py @@ -335,6 +335,10 @@ def on_worker_shutdown(sender: Any, **kwargs: Any) -> None: if not celery_is_worker_primary(sender): return + if not hasattr(sender, "primary_worker_lock"): + # primary_worker_lock will not exist when MULTI_TENANT is True + return + if not sender.primary_worker_lock: return