Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions src/memos/graph_dbs/neo4j.py
Original file line number Diff line number Diff line change
Expand Up @@ -114,14 +114,14 @@ def get_memory_count(self, memory_type: str) -> int:
)
return result.single()["count"]

def count_nodes(self, scope: str) -> int:
def node_not_exist(self, scope: str) -> int:
query = """
MATCH (n:Memory)
WHERE n.memory_type = $scope
"""
if not self.config.use_multi_db and self.config.user_name:
query += "\nAND n.user_name = $user_name"
query += "\nRETURN count(n) AS count"
query += "\nRETURN n LIMIT 1"

with self.driver.session(database=self.db_name) as session:
result = session.run(
Expand All @@ -131,7 +131,7 @@ def count_nodes(self, scope: str) -> int:
"user_name": self.config.user_name if self.config.user_name else None,
},
)
return result.single()["count"]
return result.single() is None

def remove_oldest_memory(self, memory_type: str, keep_latest: int) -> None:
"""
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -198,7 +198,7 @@ def optimize_structure(
logger.info(f"Already optimizing for {scope}. Skipping.")
return

if self.graph_store.count_nodes(scope) == 0:
if self.graph_store.node_not_exist(scope):
logger.debug(f"[GraphStructureReorganize] No nodes for scope={scope}. Skip.")
return

Expand Down