diff --git a/API/api_worker.py b/API/api_worker.py index 517574f0..77e3af88 100644 --- a/API/api_worker.py +++ b/API/api_worker.py @@ -58,7 +58,7 @@ # celery.conf.accept_content = ["application/json", "application/x-python-serialize"] celery.conf.task_track_started = True celery.conf.update(result_extended=True) -# celery.conf.task_reject_on_worker_lost = True +celery.conf.task_reject_on_worker_lost = False celery.conf.task_acks_late = False # to avoid task duplication if WORKER_PREFETCH_MULTIPLIER: