From cdebe014cf49fdc351fd8c420284ef56d3d2100c Mon Sep 17 00:00:00 2001 From: Ke Sun Date: Wed, 1 Apr 2026 18:21:16 +0800 Subject: [PATCH] fix(tasks): disable late acknowledgment for write_message task --- api/app/tasks.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/api/app/tasks.py b/api/app/tasks.py index fa2fa55d..c15aaeeb 100644 --- a/api/app/tasks.py +++ b/api/app/tasks.py @@ -1100,7 +1100,7 @@ def read_message_task(self, end_user_id: str, message: str, history: List[Dict[s } -@celery_app.task(name="app.core.memory.agent.write_message", bind=True) +@celery_app.task(name="app.core.memory.agent.write_message", bind=True, acks_late=False) def write_message_task( self, end_user_id: str,