Patch: use manager _add_memories_parallel (#721)

* update reader and search strategy

* set strategy reader and search config

* fix install problem

* fix

* fix test

* turn off graph recall

* turn off graph recall

* turn off graph recall

* fix Searcher input bug

* fix Searcher

* fix Search

* fix bug

* adjust strategy reader

* adjust strategy reader

* adjust search config input

* reformat code

* re pr

* format repair

* fix time issue

* develop feedback process

* feedback handler configuration

* upgrade feedback using

* add threshold

* update prompt

* update prompt

* fix handler

* add feedback scheduler

* add handler change node update

* add handler change node update

* add handler change node update

* add handler change node update

* fix interface input

* add chunk and ratio filter

* update stopwords

* fix messages queue

* add seach_by_keywords_LIKE

* add doc filter

* add retrieve query

* add retrieve queies

* patch info filter

* add log and make embedding safety net

* add log and make embedding safety net

* deduplicate add objects

* use _add_memories_parallel

---------

Co-authored-by: 黑布林 <[email protected]>
Co-authored-by: CaralHsi <[email protected]>
Co-authored-by: chunyu li <[email protected]>

Author: 4 people

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(

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(