fix: remove redundant task completion status update in redis queue ack

glin1993@outlook.com · glin1993@outlook.com · commit e71b9d8a451f · 2025-12-09T11:54:08.000+08:00
diff --git a/src/memos/mem_scheduler/task_schedule_modules/redis_queue.py b/src/memos/mem_scheduler/task_schedule_modules/redis_queue.py
@@ -358,7 +358,6 @@ def ack_message(
             self._redis_conn.xack(stream_key, self.consumer_group, redis_message_id)
 
             if message:
-                self.status_tracker.task_completed(task_id=message.item_id, user_id=message.user_id)
                 logger.info(
                     f"Message {message.item_id} | {message.label} | {message.content} has been acknowledged."
                 )

Original file line number	Diff line number	Diff line change
`@@ -358,7 +358,6 @@ def ack_message(`
`358`	`358`	`self._redis_conn.xack(stream_key, self.consumer_group, redis_message_id)`
`359`	`359`
`360`	`360`	`if message:`
`361`		`- self.status_tracker.task_completed(task_id=message.item_id, user_id=message.user_id)`
`362`	`361`	`logger.info(`
`363`	`362`	`f"Message {message.item_id} \| {message.label} \| {message.content} has been acknowledged."`
`364`	`363`	`)`