fix(tasks): disable late acknowledgment for write_message task
This commit is contained in:
@@ -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(
|
def write_message_task(
|
||||||
self,
|
self,
|
||||||
end_user_id: str,
|
end_user_id: str,
|
||||||
|
|||||||
Reference in New Issue
Block a user