diff --git a/src/memos/mem_feedback/feedback.py b/src/memos/mem_feedback/feedback.py index 13b4fb036..b0927fa0f 100644 --- a/src/memos/mem_feedback/feedback.py +++ b/src/memos/mem_feedback/feedback.py @@ -133,7 +133,7 @@ def _pure_add(self, user_name: str, feedback_content: str, feedback_time: str, i memories = self.mem_reader.get_memory(scene_data, type="chat", info=info) to_add_memories = [item for scene in memories for item in scene] added_ids = self._retry_db_operation( - lambda: self.memory_manager.add(to_add_memories, user_name=user_name) + lambda: self.memory_manager.add(to_add_memories, user_name=user_name, use_batch=False) ) logger.info( f"[Feedback Core: _pure_add] Pure added {len(added_ids)} memories for user {user_name}." @@ -224,10 +224,10 @@ def _single_add_operation( to_add_memory.id = "" added_ids = self._retry_db_operation( - lambda: self.memory_manager.add([to_add_memory], user_name=user_name, mode=async_mode) + lambda: self.memory_manager.add([to_add_memory], user_name=user_name, use_batch=False) ) - logger.info(f"[Memory Feedback ADD] memory id: {added_ids[0]}") + logger.info(f"[Memory Feedback ADD] memory id: {added_ids!s}") return {"id": added_ids[0], "text": to_add_memory.memory} def _single_update_operation( diff --git a/src/memos/memories/textual/tree_text_memory/organize/manager.py b/src/memos/memories/textual/tree_text_memory/organize/manager.py index c8c3cb01c..95f4e780d 100644 --- a/src/memos/memories/textual/tree_text_memory/organize/manager.py +++ b/src/memos/memories/textual/tree_text_memory/organize/manager.py @@ -131,6 +131,7 @@ def _add_memories_parallel( added_ids.extend(ids) except Exception as e: logger.exception("Memory processing error: ", exc_info=e) + logger.info(f"[MemoryManager: _add_memories_parallel] Added {len(added_ids)} memories") return added_ids def _add_memories_batch(