diff --git a/celeryconfig.py b/celeryconfig.py index 16560b3..150caba 100644 --- a/celeryconfig.py +++ b/celeryconfig.py @@ -43,7 +43,7 @@ def init(**kwargs): # for some reason, celery seems to swallow exceptions in init print(f"Error loading {model_id}:") traceback.print_exc() - raise WorkerShutdown() + raise WorkerShutdown(1) init_fns.append(init)