From 42137926b7cb4065c4584c92ee2931a615ee1b0f Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Thu, 18 Dec 2025 11:31:33 +0800
Subject: [PATCH 1/9] feat: propagate item_id in scheduler and dispatcher logs

---
 .../general_modules/scheduler_logger.py       | 26 ++++++++++++-------
 src/memos/mem_scheduler/general_scheduler.py  | 12 +++++++++
 .../task_schedule_modules/dispatcher.py       |  6 +++++
 3 files changed, 34 insertions(+), 10 deletions(-)

diff --git a/src/memos/mem_scheduler/general_modules/scheduler_logger.py b/src/memos/mem_scheduler/general_modules/scheduler_logger.py
index 57d78676f..f52d8aa99 100644
--- a/src/memos/mem_scheduler/general_modules/scheduler_logger.py
+++ b/src/memos/mem_scheduler/general_modules/scheduler_logger.py
@@ -49,6 +49,7 @@ def create_autofilled_log_item(
         user_id: str,
         mem_cube_id: str,
         mem_cube: GeneralMemCube,
+        item_id: str | None = None,
     ) -> ScheduleLogForWebItem:
         if mem_cube is None:
             logger.error(
@@ -94,16 +95,19 @@ def create_autofilled_log_item(
             )
             memory_capacities["parameter_memory_capacity"] = 1
 
-        log_message = ScheduleLogForWebItem(
-            user_id=user_id,
-            mem_cube_id=mem_cube_id,
-            label=label,
-            from_memory_type=from_memory_type,
-            to_memory_type=to_memory_type,
-            log_content=log_content,
-            current_memory_sizes=current_memory_sizes,
-            memory_capacities=memory_capacities,
-        )
+        log_kwargs = {
+            "user_id": user_id,
+            "mem_cube_id": mem_cube_id,
+            "label": label,
+            "from_memory_type": from_memory_type,
+            "to_memory_type": to_memory_type,
+            "log_content": log_content,
+            "current_memory_sizes": current_memory_sizes,
+            "memory_capacities": memory_capacities,
+        }
+        if item_id:
+            log_kwargs["item_id"] = item_id
+        log_message = ScheduleLogForWebItem(**log_kwargs)
         return log_message
 
     @log_exceptions(logger=logger)
@@ -120,6 +124,7 @@ def create_event_log(
         memory_len: int,
         memcube_name: str | None = None,
         log_content: str | None = None,
+        item_id: str | None = None,
     ) -> ScheduleLogForWebItem:
         item = self.create_autofilled_log_item(
             log_content=log_content or "",
@@ -129,6 +134,7 @@ def create_event_log(
             user_id=user_id,
             mem_cube_id=mem_cube_id,
             mem_cube=mem_cube,
+            item_id=item_id,
         )
         item.memcube_log_content = memcube_log_content
         item.metadata = metadata
diff --git a/src/memos/mem_scheduler/general_scheduler.py b/src/memos/mem_scheduler/general_scheduler.py
index 86066f346..d3f3794a2 100644
--- a/src/memos/mem_scheduler/general_scheduler.py
+++ b/src/memos/mem_scheduler/general_scheduler.py
@@ -266,6 +266,7 @@ def _query_message_consumer(self, messages: list[ScheduleMessageItem]) -> None:
                             metadata=[],
                             memory_len=1,
                             memcube_name=self._map_memcube_name(msg.mem_cube_id),
+                            item_id=msg.item_id,
                         )
                         event.task_id = msg.task_id
                         self._submit_web_logs([event])
@@ -322,6 +323,7 @@ def _answer_message_consumer(self, messages: list[ScheduleMessageItem]) -> None:
                             metadata=[],
                             memory_len=1,
                             memcube_name=self._map_memcube_name(msg.mem_cube_id),
+                            item_id=msg.item_id,
                         )
                         event.task_id = msg.task_id
                         self._submit_web_logs([event])
@@ -492,6 +494,7 @@ def send_add_log_messages_to_local_env(
                 metadata=add_meta_legacy,
                 memory_len=len(add_content_legacy),
                 memcube_name=self._map_memcube_name(msg.mem_cube_id),
+                item_id=msg.item_id,
             )
             event.task_id = msg.task_id
             events.append(event)
@@ -507,6 +510,7 @@ def send_add_log_messages_to_local_env(
                 metadata=update_meta_legacy,
                 memory_len=len(update_content_legacy),
                 memcube_name=self._map_memcube_name(msg.mem_cube_id),
+                item_id=msg.item_id,
             )
             event.task_id = msg.task_id
             events.append(event)
@@ -573,6 +577,7 @@ def send_add_log_messages_to_cloud_env(
                 metadata=None,
                 memory_len=len(kb_log_content),
                 memcube_name=self._map_memcube_name(msg.mem_cube_id),
+                item_id=msg.item_id,
             )
             event.log_content = f"Knowledge Base Memory Update: {len(kb_log_content)} changes."
             event.task_id = msg.task_id
@@ -719,6 +724,7 @@ def _extract_fields(mem_item):
                         metadata=None,
                         memory_len=len(kb_log_content),
                         memcube_name=self._map_memcube_name(mem_cube_id),
+                        item_id=message.item_id,
                     )
                     event.log_content = (
                         f"Knowledge Base Memory Update: {len(kb_log_content)} changes."
@@ -788,6 +794,7 @@ def process_message(message: ScheduleMessageItem):
                     user_name=user_name,
                     custom_tags=info.get("custom_tags", None),
                     task_id=message.task_id,
+                    item_id=message.item_id,
                     info=info,
                 )
 
@@ -815,6 +822,7 @@ def _process_memories_with_reader(
         user_name: str,
         custom_tags: list[str] | None = None,
         task_id: str | None = None,
+        item_id: str | None = None,
         info: dict | None = None,
     ) -> None:
         logger.info(
@@ -934,6 +942,7 @@ def _process_memories_with_reader(
                                 metadata=None,
                                 memory_len=len(kb_log_content),
                                 memcube_name=self._map_memcube_name(mem_cube_id),
+                                item_id=item_id,
                             )
                             event.log_content = (
                                 f"Knowledge Base Memory Update: {len(kb_log_content)} changes."
@@ -979,6 +988,7 @@ def _process_memories_with_reader(
                                 metadata=add_meta_legacy,
                                 memory_len=len(add_content_legacy),
                                 memcube_name=self._map_memcube_name(mem_cube_id),
+                                item_id=item_id,
                             )
                             event.task_id = task_id
                             self._submit_web_logs([event])
@@ -1045,6 +1055,7 @@ def _process_memories_with_reader(
                         metadata=None,
                         memory_len=len(kb_log_content),
                         memcube_name=self._map_memcube_name(mem_cube_id),
+                        item_id=item_id,
                     )
                     event.log_content = f"Knowledge Base Memory Update failed: {exc!s}"
                     event.task_id = task_id
@@ -1212,6 +1223,7 @@ def process_message(message: ScheduleMessageItem):
                             metadata=meta,
                             memory_len=len(keys),
                             memcube_name=self._map_memcube_name(mem_cube_id),
+                            item_id=message.item_id,
                         )
                         self._submit_web_logs([event])
 
diff --git a/src/memos/mem_scheduler/task_schedule_modules/dispatcher.py b/src/memos/mem_scheduler/task_schedule_modules/dispatcher.py
index 35df3db64..b048bbf6b 100644
--- a/src/memos/mem_scheduler/task_schedule_modules/dispatcher.py
+++ b/src/memos/mem_scheduler/task_schedule_modules/dispatcher.py
@@ -329,6 +329,7 @@ def _maybe_emit_task_completion(
         # messages in one batch can belong to different business task_ids; check each
         task_ids = set()
         task_id_to_doc_id = {}
+        task_id_to_item_id = {}
 
         for msg in messages:
             tid = getattr(msg, "task_id", None)
@@ -340,6 +341,8 @@ def _maybe_emit_task_completion(
                     sid = info.get("source_doc_id")
                     if sid:
                         task_id_to_doc_id[tid] = sid
+                if tid not in task_id_to_item_id:
+                    task_id_to_item_id[tid] = msg.item_id
 
         if not task_ids:
             return
@@ -356,6 +359,7 @@ def _maybe_emit_task_completion(
 
             for task_id in task_ids:
                 source_doc_id = task_id_to_doc_id.get(task_id)
+                event_item_id = task_id_to_item_id.get(task_id)
                 status_data = self.status_tracker.get_task_status_by_business_id(
                     business_task_id=task_id, user_id=user_id
                 )
@@ -369,6 +373,7 @@ def _maybe_emit_task_completion(
                     # (Although if status is 'completed', local error shouldn't happen theoretically,
                     # unless status update lags or is inconsistent. We trust status_tracker here.)
                     event = ScheduleLogForWebItem(
+                        item_id=event_item_id,
                         task_id=task_id,
                         user_id=user_id,
                         mem_cube_id=mem_cube_id,
@@ -393,6 +398,7 @@ def _maybe_emit_task_completion(
                             error_msg = "Unknown error (check system logs)"
 
                     event = ScheduleLogForWebItem(
+                        item_id=event_item_id,
                         task_id=task_id,
                         user_id=user_id,
                         mem_cube_id=mem_cube_id,

From 839aacd2368bd10ea6f72745a544bff646d103d5 Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Thu, 18 Dec 2025 13:18:33 +0800
Subject: [PATCH 2/9] remove web log queue put

---
 src/memos/mem_scheduler/base_scheduler.py | 5 -----
 tests/mem_scheduler/test_scheduler.py     | 7 -------
 2 files changed, 12 deletions(-)

diff --git a/src/memos/mem_scheduler/base_scheduler.py b/src/memos/mem_scheduler/base_scheduler.py
index 8e4ca9fcb..ff4f7caff 100644
--- a/src/memos/mem_scheduler/base_scheduler.py
+++ b/src/memos/mem_scheduler/base_scheduler.py
@@ -853,11 +853,6 @@ def _submit_web_logs(
             return
 
         for message in messages:
-            try:
-                self._web_log_message_queue.put(message)
-            except Exception as e:
-                logger.warning(f"Failed to put message to web log queue: {e}", stack_info=True)
-
             message_info = message.debug_info()
             logger.debug(f"Submitted Scheduling log for web: {message_info}")
 
diff --git a/tests/mem_scheduler/test_scheduler.py b/tests/mem_scheduler/test_scheduler.py
index 5b68a8bad..61fe12f5b 100644
--- a/tests/mem_scheduler/test_scheduler.py
+++ b/tests/mem_scheduler/test_scheduler.py
@@ -139,16 +139,9 @@ def test_submit_web_logs(self):
             },
         )
 
-        # Empty the queue by consuming all elements
-        while not self.scheduler._web_log_message_queue.empty():
-            self.scheduler._web_log_message_queue.get()
-
         # Submit the log message
         self.scheduler._submit_web_logs(messages=log_message)
 
-        # Verify the message was added to the queue
-        self.assertEqual(self.scheduler._web_log_message_queue.qsize(), 1)
-
         # Get the actual message from the queue
         actual_message = self.scheduler._web_log_message_queue.get()
 

From a44386d68a3478218582719f8522fb3fd6a3cd9a Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Thu, 18 Dec 2025 13:20:57 +0800
Subject: [PATCH 3/9] chore: add diagnostic logs for publish

---
 src/memos/mem_scheduler/base_scheduler.py                | 7 +++++++
 .../mem_scheduler/webservice_modules/rabbitmq_service.py | 9 +++++++++
 2 files changed, 16 insertions(+)

diff --git a/src/memos/mem_scheduler/base_scheduler.py b/src/memos/mem_scheduler/base_scheduler.py
index ff4f7caff..d6702c25f 100644
--- a/src/memos/mem_scheduler/base_scheduler.py
+++ b/src/memos/mem_scheduler/base_scheduler.py
@@ -861,6 +861,13 @@ def _submit_web_logs(
                 f"[DIAGNOSTIC] base_scheduler._submit_web_logs: enqueue publish {message_info}"
             )
             self.rabbitmq_publish_message(message=message.to_dict())
+            logger.info(
+                "[DIAGNOSTIC] base_scheduler._submit_web_logs: publish dispatched "
+                "item_id=%s task_id=%s label=%s",
+                message.item_id,
+                message.task_id,
+                message.label,
+            )
         logger.debug(
             f"{len(messages)} submitted. {self._web_log_message_queue.qsize()} in queue. additional_log_info: {additional_log_info}"
         )
diff --git a/src/memos/mem_scheduler/webservice_modules/rabbitmq_service.py b/src/memos/mem_scheduler/webservice_modules/rabbitmq_service.py
index 9c85a4872..a8a09760c 100644
--- a/src/memos/mem_scheduler/webservice_modules/rabbitmq_service.py
+++ b/src/memos/mem_scheduler/webservice_modules/rabbitmq_service.py
@@ -368,6 +368,15 @@ def rabbitmq_publish_message(self, message: dict):
                 logger.debug(f"Published message: {message}")
                 return True
             except Exception as e:
+                logger.error(
+                    "[DIAGNOSTIC] RabbitMQ publish error. label=%s item_id=%s exchange=%s "
+                    "routing_key=%s error=%s",
+                    label,
+                    message.get("item_id"),
+                    exchange_name,
+                    routing_key,
+                    e,
+                )
                 logger.error(f"Failed to publish message: {e}")
                 # Cache message for retry on next connection
                 self.rabbitmq_publish_cache.put(message)

From 08ce9c17fc03714b8af48c8ce6ba4a83f42efc7d Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Thu, 18 Dec 2025 13:26:32 +0800
Subject: [PATCH 4/9] chore: log submitted web log at info

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

diff --git a/src/memos/mem_scheduler/base_scheduler.py b/src/memos/mem_scheduler/base_scheduler.py
index d6702c25f..81defaa0f 100644
--- a/src/memos/mem_scheduler/base_scheduler.py
+++ b/src/memos/mem_scheduler/base_scheduler.py
@@ -854,7 +854,7 @@ def _submit_web_logs(
 
         for message in messages:
             message_info = message.debug_info()
-            logger.debug(f"Submitted Scheduling log for web: {message_info}")
+            logger.info(f"[DIAGNOSTIC] base_scheduler._submit_web_logs: submitted {message_info}")
 
             # Always call publish; the publisher now caches when offline and flushes after reconnect
             logger.info(

From b46d0623298617f14bd9d84959abe84503d491fb Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Thu, 18 Dec 2025 13:27:13 +0800
Subject: [PATCH 5/9] chore: rename log_id to item_id in debug info

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

diff --git a/src/memos/mem_scheduler/schemas/message_schemas.py b/src/memos/mem_scheduler/schemas/message_schemas.py
index db28f3d71..cf3019d5e 100644
--- a/src/memos/mem_scheduler/schemas/message_schemas.py
+++ b/src/memos/mem_scheduler/schemas/message_schemas.py
@@ -163,7 +163,7 @@ def debug_info(self) -> dict[str, Any]:
         """Return structured debug information for logging purposes."""
         return {
             "content_preview:": self.log_content[:50],
-            "log_id": self.item_id,
+            "item_id": self.item_id,
             "user_id": self.user_id,
             "mem_cube_id": self.mem_cube_id,
             "operation": f"{self.from_memory_type} → {self.to_memory_type}",

From c3001f2bc105671c08fff940526311bae0d71100 Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Thu, 18 Dec 2025 13:41:19 +0800
Subject: [PATCH 6/9] test: avoid web log queue dependency

---
 tests/mem_scheduler/test_scheduler.py | 36 ++++++++-------------------
 1 file changed, 10 insertions(+), 26 deletions(-)

diff --git a/tests/mem_scheduler/test_scheduler.py b/tests/mem_scheduler/test_scheduler.py
index 61fe12f5b..523d5d108 100644
--- a/tests/mem_scheduler/test_scheduler.py
+++ b/tests/mem_scheduler/test_scheduler.py
@@ -139,37 +139,21 @@ def test_submit_web_logs(self):
             },
         )
 
+        self.scheduler.rabbitmq_config = MagicMock()
+        self.scheduler.rabbitmq_publish_message = MagicMock()
+
         # Submit the log message
         self.scheduler._submit_web_logs(messages=log_message)
 
-        # Get the actual message from the queue
-        actual_message = self.scheduler._web_log_message_queue.get()
-
-        # Verify core fields
-        self.assertEqual(actual_message.user_id, "test_user")
-        self.assertEqual(actual_message.mem_cube_id, "test_cube")
-        self.assertEqual(actual_message.label, QUERY_TASK_LABEL)
-        self.assertEqual(actual_message.from_memory_type, "WorkingMemory")
-        self.assertEqual(actual_message.to_memory_type, "LongTermMemory")
-        self.assertEqual(actual_message.log_content, "Test Content")
-
-        # Verify memory sizes
-        self.assertEqual(actual_message.current_memory_sizes["long_term_memory_size"], 0)
-        self.assertEqual(actual_message.current_memory_sizes["user_memory_size"], 0)
-        self.assertEqual(actual_message.current_memory_sizes["working_memory_size"], 0)
-        self.assertEqual(actual_message.current_memory_sizes["transformed_act_memory_size"], 0)
-
-        # Verify memory capacities
-        self.assertEqual(actual_message.memory_capacities["long_term_memory_capacity"], 1000)
-        self.assertEqual(actual_message.memory_capacities["user_memory_capacity"], 500)
-        self.assertEqual(actual_message.memory_capacities["working_memory_capacity"], 100)
-        self.assertEqual(actual_message.memory_capacities["transformed_act_memory_capacity"], 0)
+        self.scheduler.rabbitmq_publish_message.assert_called_once_with(
+            message=log_message.to_dict()
+        )
 
         # Verify auto-generated fields exist
-        self.assertTrue(hasattr(actual_message, "item_id"))
-        self.assertTrue(isinstance(actual_message.item_id, str))
-        self.assertTrue(hasattr(actual_message, "timestamp"))
-        self.assertTrue(isinstance(actual_message.timestamp, datetime))
+        self.assertTrue(hasattr(log_message, "item_id"))
+        self.assertTrue(isinstance(log_message.item_id, str))
+        self.assertTrue(hasattr(log_message, "timestamp"))
+        self.assertTrue(isinstance(log_message.timestamp, datetime))
 
     def test_activation_memory_update(self):
         """Test activation memory update functionality with DynamicCache handling."""

From 0a0948e9739132764264064460f70ee91c9d6f2e Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Thu, 18 Dec 2025 14:01:59 +0800
Subject: [PATCH 7/9] Revert "feat: propagate item_id in scheduler and
 dispatcher logs"

This reverts commit 42137926b7cb4065c4584c92ee2931a615ee1b0f.
---
 .../general_modules/scheduler_logger.py       | 26 +++++++------------
 src/memos/mem_scheduler/general_scheduler.py  | 12 ---------
 .../task_schedule_modules/dispatcher.py       |  6 -----
 3 files changed, 10 insertions(+), 34 deletions(-)

diff --git a/src/memos/mem_scheduler/general_modules/scheduler_logger.py b/src/memos/mem_scheduler/general_modules/scheduler_logger.py
index f52d8aa99..57d78676f 100644
--- a/src/memos/mem_scheduler/general_modules/scheduler_logger.py
+++ b/src/memos/mem_scheduler/general_modules/scheduler_logger.py
@@ -49,7 +49,6 @@ def create_autofilled_log_item(
         user_id: str,
         mem_cube_id: str,
         mem_cube: GeneralMemCube,
-        item_id: str | None = None,
     ) -> ScheduleLogForWebItem:
         if mem_cube is None:
             logger.error(
@@ -95,19 +94,16 @@ def create_autofilled_log_item(
             )
             memory_capacities["parameter_memory_capacity"] = 1
 
-        log_kwargs = {
-            "user_id": user_id,
-            "mem_cube_id": mem_cube_id,
-            "label": label,
-            "from_memory_type": from_memory_type,
-            "to_memory_type": to_memory_type,
-            "log_content": log_content,
-            "current_memory_sizes": current_memory_sizes,
-            "memory_capacities": memory_capacities,
-        }
-        if item_id:
-            log_kwargs["item_id"] = item_id
-        log_message = ScheduleLogForWebItem(**log_kwargs)
+        log_message = ScheduleLogForWebItem(
+            user_id=user_id,
+            mem_cube_id=mem_cube_id,
+            label=label,
+            from_memory_type=from_memory_type,
+            to_memory_type=to_memory_type,
+            log_content=log_content,
+            current_memory_sizes=current_memory_sizes,
+            memory_capacities=memory_capacities,
+        )
         return log_message
 
     @log_exceptions(logger=logger)
@@ -124,7 +120,6 @@ def create_event_log(
         memory_len: int,
         memcube_name: str | None = None,
         log_content: str | None = None,
-        item_id: str | None = None,
     ) -> ScheduleLogForWebItem:
         item = self.create_autofilled_log_item(
             log_content=log_content or "",
@@ -134,7 +129,6 @@ def create_event_log(
             user_id=user_id,
             mem_cube_id=mem_cube_id,
             mem_cube=mem_cube,
-            item_id=item_id,
         )
         item.memcube_log_content = memcube_log_content
         item.metadata = metadata
diff --git a/src/memos/mem_scheduler/general_scheduler.py b/src/memos/mem_scheduler/general_scheduler.py
index d3f3794a2..86066f346 100644
--- a/src/memos/mem_scheduler/general_scheduler.py
+++ b/src/memos/mem_scheduler/general_scheduler.py
@@ -266,7 +266,6 @@ def _query_message_consumer(self, messages: list[ScheduleMessageItem]) -> None:
                             metadata=[],
                             memory_len=1,
                             memcube_name=self._map_memcube_name(msg.mem_cube_id),
-                            item_id=msg.item_id,
                         )
                         event.task_id = msg.task_id
                         self._submit_web_logs([event])
@@ -323,7 +322,6 @@ def _answer_message_consumer(self, messages: list[ScheduleMessageItem]) -> None:
                             metadata=[],
                             memory_len=1,
                             memcube_name=self._map_memcube_name(msg.mem_cube_id),
-                            item_id=msg.item_id,
                         )
                         event.task_id = msg.task_id
                         self._submit_web_logs([event])
@@ -494,7 +492,6 @@ def send_add_log_messages_to_local_env(
                 metadata=add_meta_legacy,
                 memory_len=len(add_content_legacy),
                 memcube_name=self._map_memcube_name(msg.mem_cube_id),
-                item_id=msg.item_id,
             )
             event.task_id = msg.task_id
             events.append(event)
@@ -510,7 +507,6 @@ def send_add_log_messages_to_local_env(
                 metadata=update_meta_legacy,
                 memory_len=len(update_content_legacy),
                 memcube_name=self._map_memcube_name(msg.mem_cube_id),
-                item_id=msg.item_id,
             )
             event.task_id = msg.task_id
             events.append(event)
@@ -577,7 +573,6 @@ def send_add_log_messages_to_cloud_env(
                 metadata=None,
                 memory_len=len(kb_log_content),
                 memcube_name=self._map_memcube_name(msg.mem_cube_id),
-                item_id=msg.item_id,
             )
             event.log_content = f"Knowledge Base Memory Update: {len(kb_log_content)} changes."
             event.task_id = msg.task_id
@@ -724,7 +719,6 @@ def _extract_fields(mem_item):
                         metadata=None,
                         memory_len=len(kb_log_content),
                         memcube_name=self._map_memcube_name(mem_cube_id),
-                        item_id=message.item_id,
                     )
                     event.log_content = (
                         f"Knowledge Base Memory Update: {len(kb_log_content)} changes."
@@ -794,7 +788,6 @@ def process_message(message: ScheduleMessageItem):
                     user_name=user_name,
                     custom_tags=info.get("custom_tags", None),
                     task_id=message.task_id,
-                    item_id=message.item_id,
                     info=info,
                 )
 
@@ -822,7 +815,6 @@ def _process_memories_with_reader(
         user_name: str,
         custom_tags: list[str] | None = None,
         task_id: str | None = None,
-        item_id: str | None = None,
         info: dict | None = None,
     ) -> None:
         logger.info(
@@ -942,7 +934,6 @@ def _process_memories_with_reader(
                                 metadata=None,
                                 memory_len=len(kb_log_content),
                                 memcube_name=self._map_memcube_name(mem_cube_id),
-                                item_id=item_id,
                             )
                             event.log_content = (
                                 f"Knowledge Base Memory Update: {len(kb_log_content)} changes."
@@ -988,7 +979,6 @@ def _process_memories_with_reader(
                                 metadata=add_meta_legacy,
                                 memory_len=len(add_content_legacy),
                                 memcube_name=self._map_memcube_name(mem_cube_id),
-                                item_id=item_id,
                             )
                             event.task_id = task_id
                             self._submit_web_logs([event])
@@ -1055,7 +1045,6 @@ def _process_memories_with_reader(
                         metadata=None,
                         memory_len=len(kb_log_content),
                         memcube_name=self._map_memcube_name(mem_cube_id),
-                        item_id=item_id,
                     )
                     event.log_content = f"Knowledge Base Memory Update failed: {exc!s}"
                     event.task_id = task_id
@@ -1223,7 +1212,6 @@ def process_message(message: ScheduleMessageItem):
                             metadata=meta,
                             memory_len=len(keys),
                             memcube_name=self._map_memcube_name(mem_cube_id),
-                            item_id=message.item_id,
                         )
                         self._submit_web_logs([event])
 
diff --git a/src/memos/mem_scheduler/task_schedule_modules/dispatcher.py b/src/memos/mem_scheduler/task_schedule_modules/dispatcher.py
index b048bbf6b..35df3db64 100644
--- a/src/memos/mem_scheduler/task_schedule_modules/dispatcher.py
+++ b/src/memos/mem_scheduler/task_schedule_modules/dispatcher.py
@@ -329,7 +329,6 @@ def _maybe_emit_task_completion(
         # messages in one batch can belong to different business task_ids; check each
         task_ids = set()
         task_id_to_doc_id = {}
-        task_id_to_item_id = {}
 
         for msg in messages:
             tid = getattr(msg, "task_id", None)
@@ -341,8 +340,6 @@ def _maybe_emit_task_completion(
                     sid = info.get("source_doc_id")
                     if sid:
                         task_id_to_doc_id[tid] = sid
-                if tid not in task_id_to_item_id:
-                    task_id_to_item_id[tid] = msg.item_id
 
         if not task_ids:
             return
@@ -359,7 +356,6 @@ def _maybe_emit_task_completion(
 
             for task_id in task_ids:
                 source_doc_id = task_id_to_doc_id.get(task_id)
-                event_item_id = task_id_to_item_id.get(task_id)
                 status_data = self.status_tracker.get_task_status_by_business_id(
                     business_task_id=task_id, user_id=user_id
                 )
@@ -373,7 +369,6 @@ def _maybe_emit_task_completion(
                     # (Although if status is 'completed', local error shouldn't happen theoretically,
                     # unless status update lags or is inconsistent. We trust status_tracker here.)
                     event = ScheduleLogForWebItem(
-                        item_id=event_item_id,
                         task_id=task_id,
                         user_id=user_id,
                         mem_cube_id=mem_cube_id,
@@ -398,7 +393,6 @@ def _maybe_emit_task_completion(
                             error_msg = "Unknown error (check system logs)"
 
                     event = ScheduleLogForWebItem(
-                        item_id=event_item_id,
                         task_id=task_id,
                         user_id=user_id,
                         mem_cube_id=mem_cube_id,

From b15d9ea832e460c12aa4fbf36a1447a62e1034e3 Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Thu, 18 Dec 2025 14:01:59 +0800
Subject: [PATCH 8/9] Revert "chore: rename log_id to item_id in debug info"

This reverts commit b46d0623298617f14bd9d84959abe84503d491fb.
---
 src/memos/mem_scheduler/schemas/message_schemas.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/memos/mem_scheduler/schemas/message_schemas.py b/src/memos/mem_scheduler/schemas/message_schemas.py
index cf3019d5e..db28f3d71 100644
--- a/src/memos/mem_scheduler/schemas/message_schemas.py
+++ b/src/memos/mem_scheduler/schemas/message_schemas.py
@@ -163,7 +163,7 @@ def debug_info(self) -> dict[str, Any]:
         """Return structured debug information for logging purposes."""
         return {
             "content_preview:": self.log_content[:50],
-            "item_id": self.item_id,
+            "log_id": self.item_id,
             "user_id": self.user_id,
             "mem_cube_id": self.mem_cube_id,
             "operation": f"{self.from_memory_type} → {self.to_memory_type}",

From 3d7b3cf468b4c9211a8456d21c6a7ee969c76639 Mon Sep 17 00:00:00 2001
From: "glin1993@outlook.com" <>
Date: Thu, 18 Dec 2025 14:03:36 +0800
Subject: [PATCH 9/9] chore: use item_id in debug info

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

diff --git a/src/memos/mem_scheduler/schemas/message_schemas.py b/src/memos/mem_scheduler/schemas/message_schemas.py
index db28f3d71..cf3019d5e 100644
--- a/src/memos/mem_scheduler/schemas/message_schemas.py
+++ b/src/memos/mem_scheduler/schemas/message_schemas.py
@@ -163,7 +163,7 @@ def debug_info(self) -> dict[str, Any]:
         """Return structured debug information for logging purposes."""
         return {
             "content_preview:": self.log_content[:50],
-            "log_id": self.item_id,
+            "item_id": self.item_id,
             "user_id": self.user_id,
             "mem_cube_id": self.mem_cube_id,
             "operation": f"{self.from_memory_type} → {self.to_memory_type}",