gmakstutis/LightRAG
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

As Graph edges should be treated undirectional, fix incorrect upsert_edge method in MongoDBGraph

Browse source
This commit is contained in:
Ken Chen 2025-06-28 21:03:54 +08:00
parent 5116d61eaa
commit 4a953d6829
1 changed files with 16 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
lightrag/kg/mongo_impl.py
View file

@ -663,7 +663,7 @@ class MongoGraphStorage(BaseGraphStorage):
self, source_node_id: str, target_node_id: str, edge_data: dict[str, str] self, source_node_id: str, target_node_id: str, edge_data: dict[str, str]
) -> None: ) -> None:
""" """
Upsert an edge from source_node_id -> target_node_id with optional 'relation'. Upsert an edge between source_node_id and target_node_id with optional 'relation'.
If an edge with the same target exists, we remove it and re-insert with updated data. If an edge with the same target exists, we remove it and re-insert with updated data.
""" """
# Ensure source node exists # Ensure source node exists
@ -675,8 +675,22 @@ class MongoGraphStorage(BaseGraphStorage):
GRAPH_FIELD_SEP GRAPH_FIELD_SEP
) )
edge_data["source_node_id"] = source_node_id
edge_data["target_node_id"] = target_node_id
await self.edge_collection.update_one( await self.edge_collection.update_one(
{"source_node_id": source_node_id, "target_node_id": target_node_id}, {
"$or": [
{
"source_node_id": source_node_id,
"target_node_id": target_node_id,
},
{
"source_node_id": target_node_id,
"target_node_id": source_node_id,
},
]
},
update_doc, update_doc,
upsert=True, upsert=True,
) )