fix(taskreject): avoid worker acks

hotosm · Feb 18, 2025 · 532e977 · 532e977
1 parent d03e0ea
commit 532e977
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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: