From 6b196f6da4436848a9beb011c9c802d9ab283ea6 Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Fri, 28 Nov 2025 15:28:19 +0800
Subject: [PATCH 1/2] hotfix: align KB knowledgeBaseUpdate logs with spec

---
 src/memos/mem_scheduler/general_scheduler.py | 18 ++++++++++++++----
 1 file changed, 14 insertions(+), 4 deletions(-)

diff --git a/src/memos/mem_scheduler/general_scheduler.py b/src/memos/mem_scheduler/general_scheduler.py
index c3dba6d8c..fd8030a33 100644
--- a/src/memos/mem_scheduler/general_scheduler.py
+++ b/src/memos/mem_scheduler/general_scheduler.py
@@ -367,7 +367,8 @@ def _add_message_consumer(self, messages: list[ScheduleMessageItem]) -> None:
                             if kb_log_content:
                                 event = self.create_event_log(
                                     label="knowledgeBaseUpdate",
-                                    log_content=f"Knowledge Base Memory Update: {len(kb_log_content)} changes.",
+                                    from_memory_type=USER_INPUT_TYPE,
+                                    to_memory_type=LONG_TERM_MEMORY_TYPE,
                                     user_id=msg.user_id,
                                     mem_cube_id=msg.mem_cube_id,
                                     mem_cube=self.current_mem_cube,
@@ -376,6 +377,9 @@ def _add_message_consumer(self, messages: list[ScheduleMessageItem]) -> None:
                                     memory_len=len(kb_log_content),
                                     memcube_name=self._map_memcube_name(msg.mem_cube_id),
                                 )
+                                event.log_content = (
+                                    f"Knowledge Base Memory Update: {len(kb_log_content)} changes."
+                                )
                                 event.task_id = msg.task_id
                                 self._submit_web_logs([event])
                         else:
@@ -629,11 +633,12 @@ def _process_memories_with_reader(
                                     "original_content": None,
                                     "source_doc_id": getattr(item.metadata, "source_doc_id", None),
                                 }
-                            )
+                        )
                         if kb_log_content:
                             event = self.create_event_log(
                                 label="knowledgeBaseUpdate",
-                                log_content=f"Knowledge Base Memory Update: {len(kb_log_content)} changes.",
+                                from_memory_type=USER_INPUT_TYPE,
+                                to_memory_type=LONG_TERM_MEMORY_TYPE,
                                 user_id=user_id,
                                 mem_cube_id=mem_cube_id,
                                 mem_cube=self.current_mem_cube,
@@ -642,6 +647,9 @@ def _process_memories_with_reader(
                                 memory_len=len(kb_log_content),
                                 memcube_name=self._map_memcube_name(mem_cube_id),
                             )
+                            event.log_content = (
+                                f"Knowledge Base Memory Update: {len(kb_log_content)} changes."
+                            )
                             event.task_id = task_id
                             self._submit_web_logs([event])
                     else:
@@ -742,7 +750,8 @@ def _process_memories_with_reader(
                         ]
                     event = self.create_event_log(
                         label="knowledgeBaseUpdate",
-                        log_content=f"Knowledge Base Memory Update failed: {exc!s}",
+                        from_memory_type=USER_INPUT_TYPE,
+                        to_memory_type=LONG_TERM_MEMORY_TYPE,
                         user_id=user_id,
                         mem_cube_id=mem_cube_id,
                         mem_cube=self.current_mem_cube,
@@ -751,6 +760,7 @@ def _process_memories_with_reader(
                         memory_len=len(kb_log_content),
                         memcube_name=self._map_memcube_name(mem_cube_id),
                     )
+                    event.log_content = f"Knowledge Base Memory Update failed: {exc!s}"
                     event.task_id = task_id
                     event.status = "failed"
                     self._submit_web_logs([event])

From ded835510290b70e80785a7d5f2af7f05e6044a6 Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Fri, 28 Nov 2025 15:33:35 +0800
Subject: [PATCH 2/2] style: apply ruff format to general_scheduler

---
 src/memos/mem_scheduler/general_scheduler.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/memos/mem_scheduler/general_scheduler.py b/src/memos/mem_scheduler/general_scheduler.py
index fd8030a33..3e3298b10 100644
--- a/src/memos/mem_scheduler/general_scheduler.py
+++ b/src/memos/mem_scheduler/general_scheduler.py
@@ -633,7 +633,7 @@ def _process_memories_with_reader(
                                     "original_content": None,
                                     "source_doc_id": getattr(item.metadata, "source_doc_id", None),
                                 }
-                        )
+                            )
                         if kb_log_content:
                             event = self.create_event_log(
                                 label="knowledgeBaseUpdate",