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