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

Improve edge logging format and exception prefixes

Browse source
This commit is contained in:
yangdx 2025-09-06 08:35:52 +08:00
parent 64bbe7233b
commit 0a62f02e84
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lightrag/operate.py
View file

@ -1396,9 +1396,9 @@ async def _merge_edges_then_upsert(
# Log based on actual LLM usage # Log based on actual LLM usage
if llm_was_used: if llm_was_used:
status_message = f"LLMmrg: `{src_id} - {tgt_id}` | {already_fragment}+{num_fragment-already_fragment}{dd_message}" status_message = f"LLMmrg: `{src_id}`~`{tgt_id}` | {already_fragment}+{num_fragment-already_fragment}{dd_message}"
else: else:
status_message = f"Merged: `{src_id} - {tgt_id}` | {already_fragment}+{num_fragment-already_fragment}{dd_message}" status_message = f"Merged: `{src_id}`~`{tgt_id}` | {already_fragment}+{num_fragment-already_fragment}{dd_message}"
logger.info(status_message) logger.info(status_message)
if pipeline_status is not None and pipeline_status_lock is not None: if pipeline_status is not None and pipeline_status_lock is not None:
@ -1759,7 +1759,7 @@ async def merge_nodes_and_edges(
# Re-raise the original exception with a prefix # Re-raise the original exception with a prefix
prefixed_exception = create_prefixed_exception( prefixed_exception = create_prefixed_exception(
e, f"`{sorted_edge_key}`" e, f"{sorted_edge_key}"
) )
raise prefixed_exception from e raise prefixed_exception from e