feat: add addMessage Stage log

Author: harvey_xiang

src/memos/chunkers/sentence_chunker.py

@@ -50,7 +50,8 @@ def chunk(self, text: str) -> list[str] | list[Chunk]:
         for c in chonkie_chunks:
             chunk = Chunk(text=c.text, token_count=c.token_count, sentences=c.sentences)
             chunk = self.restore_urls(chunk.text, url_map)
-
             chunks.append(chunk)
 
+        logger.debug(f"Generated {len(chunks)} chunks from input text")
+
         return chunks

src/memos/mem_feedback/feedback.py

@@ -725,7 +725,7 @@ def filter_fault_update(self, operations: list[dict]):
         for judge in all_judge:
             valid_update = None
             if judge["judgement"] == "UPDATE_APPROVED":
-                valid_update = id2op.get(judge["id"])
+                valid_update = id2op.get(judge["id"], None)
             if valid_update:
                 valid_updates.append(valid_update)
 

src/memos/mem_reader/multi_modal_struct.py

@@ -131,7 +131,6 @@ def _create_chunk_item(chunk):
                     if split_item is not None:
                         split_items.append(split_item)
 
-            logger.info(f"[split_large] → split_items={len(split_items)}")
             return split_items if split_items else [item]
         except Exception as e:
             logger.warning(
@@ -170,8 +169,6 @@ def _concat_multi_modal_memories(
                 # Create a list to hold futures with their original index
                 futures = []
                 for idx, item in enumerate(all_memory_items):
-                    token_count = self._count_tokens(item.memory)
-                    logger.info(f"[token_count]: {token_count}, [max_tokens]: {max_tokens}")
                     if (item.memory or "") and self._count_tokens(item.memory) > max_tokens:
                         future = executor.submit(self._split_large_memory_item, item, max_tokens)
                         futures.append(