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

Reduce logging verbosity in entity merge relation processing

Browse source
This commit is contained in:
yangdx 2025-10-31 17:02:10 +08:00
parent 2496d87148
commit 6b4514c8ef
1 changed files with 12 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
lightrag/utils_graph.py
View file

@ -1342,7 +1342,7 @@ async def _merge_entities_impl(
filter_none_only=True, # Use relation behavior: only filter None
)
relation_updates[relation_key]["data"] = merged_relation
logger.info(
logger.debug(
f"Entity Merge: deduplicating relation `{normalized_src}`~`{normalized_tgt}`"
)
else:
@ -1360,7 +1360,7 @@ async def _merge_entities_impl(
rel_data["graph_src"], rel_data["graph_tgt"], rel_data["data"]
)
logger.info(
f"Entity Merge: updating relation `{rel_data['graph_src']}`->`{rel_data['graph_tgt']}`"
f"Entity Merge: updating relation `{rel_data['graph_src']}`~`{rel_data['graph_tgt']}`"
)
# Update relation chunk tracking storage
@ -1378,12 +1378,15 @@ async def _merge_entities_impl(
await relation_chunks_storage.upsert(updates)
logger.info(
f"Entity Merge: merged chunk tracking for {len(updates)} relations"
f"Entity Merge: {len(updates)} relation chunk tracking records updated"
)
# 7. Update relationship vector representations
logger.info(f"Entity Merge: deleting {len(relations_to_delete)} relations from vdb")
logger.debug(
f"Entity Merge: deleting {len(relations_to_delete)} relations from vdb"
)
await relationships_vdb.delete(relations_to_delete)
for rel_data in relation_updates.values():
edge_data = rel_data["data"]
normalized_src = rel_data["norm_src"]
@ -1410,7 +1413,11 @@ async def _merge_entities_impl(
}
}
await relationships_vdb.upsert(relation_data_for_vdb)
logger.info(f"Entity Merge: updating vdb `{normalized_src}`~`{normalized_tgt}`")
logger.debug(
f"Entity Merge: updating vdb `{normalized_src}`~`{normalized_tgt}`"
)
logger.info(f"Entity Merge: {len(relation_updates)} relations in vdb updated")
# 8. Update entity vector representation
description = merged_entity_data.get("description", "")