Merge pull request #368 from LCOGT/fix/celery-acks-late

Fix/celery acks late
LCOGT · Aug 23, 2023 · ae76583 · ae76583
2 parents 5ccd3e9 + 9d123ee
commit ae76583
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/CHANGES.md b/CHANGES.md
@@ -2,6 +2,7 @@
 -------------------
 - Added the process_by_group keyword to stages to fix a bug that wouldn't allow grouping only by instrument
 - Updated the logging scheme
+- Ack tasks late so that they may be re-queued in the event of a worker shutdown a la kubernetes
 
 1.10.1 (2023-05-31)
 -------------------

diff --git a/banzai/celeryconfig.py b/banzai/celeryconfig.py
@@ -2,3 +2,4 @@
 imports = ('banzai.main', 'banzai.celery',)
 worker_prefetch_multiplier = 1
 worker_max_tasks_per_child = 100
+task_acks_late = True