From a405a7939eedfa0a052c980de44984eac74ee0ad Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B8=AD=E9=98=B3=E9=98=B3?= <caralhsi@gmail.com>
Date: Mon, 13 Oct 2025 11:38:12 +0800
Subject: [PATCH] fix: remove old mem

---
 src/memos/graph_dbs/nebular.py | 27 +++++++++++++--------------
 1 file changed, 13 insertions(+), 14 deletions(-)

diff --git a/src/memos/graph_dbs/nebular.py b/src/memos/graph_dbs/nebular.py
index 45656b770..0eee05e74 100644
--- a/src/memos/graph_dbs/nebular.py
+++ b/src/memos/graph_dbs/nebular.py
@@ -443,21 +443,20 @@ def remove_oldest_memory(self, memory_type: str, keep_latest: int) -> None:
         if not self.config.use_multi_db and self.config.user_name:
             optional_condition = f"AND n.user_name = '{self.config.user_name}'"
 
-        count = self.count_nodes(memory_type)
-
-        if count > keep_latest:
-            delete_query = f"""
-                MATCH (n@Memory)
-                WHERE n.memory_type = '{memory_type}'
-                {optional_condition}
-                ORDER BY n.updated_at DESC
-                OFFSET {keep_latest}
-                DETACH DELETE n
-            """
-            try:
+        try:
+            count = self.count_nodes(memory_type)
+            if count > keep_latest:
+                delete_query = f"""
+                    MATCH (n@Memory)
+                    WHERE n.memory_type = '{memory_type}'
+                    {optional_condition}
+                    ORDER BY n.updated_at DESC
+                    OFFSET {keep_latest}
+                    DETACH DELETE n
+                """
                 self.execute_query(delete_query)
-            except Exception as e:
-                logger.warning(f"Delete old mem error: {e}")
+        except Exception as e:
+            logger.warning(f"Delete old mem error: {e}")
 
     @timed
     def add_node(self, id: str, memory: str, metadata: dict[str, Any]) -> None: