From 532e9777f755e726a8457b86040657b07768b7e9 Mon Sep 17 00:00:00 2001 From: kshitijrajsharma Date: Tue, 18 Feb 2025 21:59:51 +0100 Subject: [PATCH] fix(taskreject): avoid worker acks --- API/api_worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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: