From c4506438cddaea5e89bf4a9e1b7c7aeb8af3fd8c Mon Sep 17 00:00:00 2001 From: yangdx Date: Wed, 10 Sep 2025 15:14:33 +0800 Subject: [PATCH] Only log merge messages when there are existing fragments to merge --- lightrag/operate.py | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/lightrag/operate.py b/lightrag/operate.py index dcd3410a..6d251d27 100644 --- a/lightrag/operate.py +++ b/lightrag/operate.py @@ -1279,10 +1279,11 @@ async def _merge_nodes_then_upsert( ) # Log based on actual LLM usage - if llm_was_used: - status_message = f"LLMmrg: `{entity_name}` | {already_fragment}+{num_fragment - already_fragment}{dd_message}" - else: - status_message = f"Merged: `{entity_name}` | {already_fragment}+{num_fragment - already_fragment}{dd_message}" + if already_fragment > 0: + if llm_was_used: + status_message = f"LLMmrg: `{entity_name}` | {already_fragment}+{num_fragment - already_fragment}{dd_message}" + else: + status_message = f"Merged: `{entity_name}` | {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: @@ -1396,10 +1397,11 @@ 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}" - else: - status_message = f"Merged: `{src_id}`~`{tgt_id}` | {already_fragment}+{num_fragment - already_fragment}{dd_message}" + if already_fragment > 0: + if llm_was_used: + 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}" logger.info(status_message) if pipeline_status is not None and pipeline_status_lock is not None: