fix: reorganize and schedular bug (#223)

* feat: illumination fix

* fix: reorganize bug

* fix: bug for schedular config

Author: CaralHsi

src/memos/api/config.py

@@ -251,7 +251,6 @@ def get_scheduler_config() -> dict[str, Any]:
             "backend": "general_scheduler",
             "config": {
                 "top_k": int(os.getenv("MOS_SCHEDULER_TOP_K", "10")),
-                "top_n": int(os.getenv("MOS_SCHEDULER_TOP_N", "5")),
                 "act_mem_update_interval": int(
                     os.getenv("MOS_SCHEDULER_ACT_MEM_UPDATE_INTERVAL", "300")
                 ),

src/memos/memories/textual/tree_text_memory/organize/reorganizer.py

@@ -65,7 +65,7 @@ def __init__(
         self.resolver = NodeHandler(graph_store=graph_store, llm=llm, embedder=embedder)
 
         self.is_reorganize = is_reorganize
-        self._reorganize_needed = False
+        self._reorganize_needed = True
         if self.is_reorganize:
             # ____ 1. For queue message driven thread ___________
             self.thread = threading.Thread(target=self._run_message_consumer_loop)
@@ -124,8 +124,8 @@ def _run_structure_organizer_loop(self):
         """
         import schedule
 
-        schedule.every(600).seconds.do(self.optimize_structure, scope="LongTermMemory")
-        schedule.every(600).seconds.do(self.optimize_structure, scope="UserMemory")
+        schedule.every(100).seconds.do(self.optimize_structure, scope="LongTermMemory")
+        schedule.every(100).seconds.do(self.optimize_structure, scope="UserMemory")
 
         logger.info("Structure optimizer schedule started.")
         while not getattr(self, "_stop_scheduler", False):
@@ -165,7 +165,7 @@ def handle_add(self, message: QueueMessage):
             for added_node, existing_node, relation in detected_relationships:
                 self.resolver.resolve(added_node, existing_node, relation)
 
-        self._reorganize_needed = False
+        self._reorganize_needed = True
 
     def handle_remove(self, message: QueueMessage):
         logger.debug(f"Handling remove operation: {str(message)[:50]}")