Feature/memory system improvement

agent_core/core/impl/event_stream/manager.py

@@ -234,7 +234,7 @@ def _log_to_files(self, kind: str, message: str) -> None:
         Append an event to EVENT.md and optionally EVENT_UNPROCESSED.md.
 
         This method is thread-safe and handles file I/O errors gracefully.
-        Events are written in the format: [YYYY/MM/DD HH:MM:SS] [kind]: message
+        Events are written in the format: [YYYY-MM-DD HH:MM:SS] [kind]: message
 
         Args:
             kind: Event category (e.g., "action", "trigger")
@@ -243,9 +243,9 @@ def _log_to_files(self, kind: str, message: str) -> None:
         if not self._agent_file_system_path:
             return
 
-        # Format: [YYYY/MM/DD HH:MM:SS] [kind]: message — LOCAL time, matching
-        # the loguru log files.
-        timestamp = datetime.now().astimezone().strftime("%Y/%m/%d %H:%M:%S")
+        # Format: [YYYY-MM-DD HH:MM:SS] [kind]: message — LOCAL time, in the
+        # canonical stamp format shared with MEMORY.md items.
+        timestamp = datetime.now().astimezone().strftime("%Y-%m-%d %H:%M:%S")
         event_line = f"[{timestamp}] [{kind}]: {message}\n"
 
         with self._file_lock:

agent_core/core/impl/memory/bm25_index.py

@@ -22,6 +22,7 @@
     BM25Okapi = None
     _HAS_BM25 = False
 
+from agent_core.core.impl.memory.tuning import BM25_SEARCH_TOP_K
 from agent_core.utils.logger import logger
 
 
@@ -76,7 +77,9 @@ def rebuild(self, chunks: Dict[str, str]) -> None:
                 logger.warning(f"[BM25Index] Failed to build index: {e}")
                 self._bm25 = None
 
-    def search(self, query: str, top_k: int = 20) -> List[Tuple[str, float]]:
+    def search(
+        self, query: str, top_k: int = BM25_SEARCH_TOP_K
+    ) -> List[Tuple[str, float]]:
         """Return ``[(chunk_id, score)]`` sorted high-to-low. Empty when index unavailable."""
         if not query or not query.strip():
             return []