fix: message schema bug (#426)

* feat: change MOS_SCHEDULER_THREAD_POOL_MAX_WORKERS to 10000

* feat: add user_name to schedule server router

* feat: roll back to old mem-reader-prompt

* feat: add moniter in schedule

* feat: set default MEMRADER_MAX_TOKENS to 8000

* feat: add metric in schedule status

* fix: bug

* fix: base scheduler bug

* fix: message schema bug

Author: CaralHsi

src/memos/graph_dbs/polardb.py

@@ -2389,6 +2389,8 @@ def add_node(
         self, id: str, memory: str, metadata: dict[str, Any], user_name: str | None = None
     ) -> None:
         """Add a memory node to the graph."""
+        logger.info(f"In add node polardb: id-{id} memory-{memory}")
+
         # user_name comes from metadata; fallback to config if missing
         metadata["user_name"] = user_name if user_name else self.config.user_name
 
@@ -2481,6 +2483,7 @@ def add_node(
                     cursor.execute(insert_query, (id, json.dumps(properties)))
                     logger.info(f"Added node {id} to graph '{self.db_name}_graph'.")
         finally:
+            logger.info(f"In add node polardb: id-{id} memory-{memory} query-{insert_query}")
             self._return_connection(conn)
 
     def _build_node_from_agtype(self, node_agtype, embedding=None):

src/memos/mem_scheduler/schemas/message_schemas.py

@@ -46,6 +46,10 @@ class ScheduleMessageItem(BaseModel, DictConversionMixin):
         default=None,
         description="user name / display name (optional)",
     )
+    session_id: str | None = Field(
+        default=None,
+        description="session_id (optional)",
+    )
 
     # Pydantic V2 model configuration
     model_config = ConfigDict(