From 0a62f02e84c5830c32d4f7efe4d67bbfae2caa42 Mon Sep 17 00:00:00 2001 From: yangdx Date: Sat, 6 Sep 2025 08:35:52 +0800 Subject: [PATCH] Improve edge logging format and exception prefixes --- lightrag/operate.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lightrag/operate.py b/lightrag/operate.py index c73139b0..c7dc5814 100644 --- a/lightrag/operate.py +++ b/lightrag/operate.py @@ -1396,9 +1396,9 @@ async def _merge_edges_then_upsert( # Log based on actual LLM usage 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: - 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) 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 prefixed_exception = create_prefixed_exception( - e, f"`{sorted_edge_key}`" + e, f"{sorted_edge_key}" ) raise prefixed_exception from e