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

Sort description by timestamp then description length to improves merge consistency

Browse source
This commit is contained in:
yangdx 2025-09-12 13:59:26 +08:00
parent 668a7c1f16
commit 69ca447f45
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
lightrag/operate.py
View file

@ -1276,8 +1276,11 @@ async def _merge_nodes_then_upsert(
if desc not in unique_nodes:
unique_nodes[desc] = dp
# Sort description by timestamp
sorted_nodes = sorted(unique_nodes.values(), key=lambda x: x.get("timestamp", 0))
# Sort description by timestamp, then by description length (largest to smallest) when timestamps are the same
sorted_nodes = sorted(
unique_nodes.values(),
key=lambda x: (x.get("timestamp", 0), -len(x.get("description", ""))),
)
sorted_descriptions = [dp["description"] for dp in sorted_nodes]
# Combine already_description with sorted new sorted descriptions
@ -1405,8 +1408,11 @@ async def _merge_edges_then_upsert(
if desc not in unique_edges:
unique_edges[desc] = dp
# Sort description by timestamp
sorted_edges = sorted(unique_edges.values(), key=lambda x: x.get("timestamp", 0))
# Sort description by timestamp, then by description length (largest to smallest) when timestamps are the same
sorted_edges = sorted(
unique_edges.values(),
key=lambda x: (x.get("timestamp", 0), -len(x.get("description", ""))),
)
sorted_descriptions = [dp["description"] for dp in sorted_edges]
# Combine already_description with sorted new descriptions