diff --git a/lightrag/operate.py b/lightrag/operate.py index f25756cb..9bfeebd8 100644 --- a/lightrag/operate.py +++ b/lightrag/operate.py @@ -1340,17 +1340,20 @@ async def _merge_nodes_then_upsert( ) # Log based on actual LLM usage - if already_fragment > 0 or llm_was_used: - 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 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 or llm_was_used: logger.info(status_message) if pipeline_status is not None and pipeline_status_lock is not None: async with pipeline_status_lock: pipeline_status["latest_message"] = status_message pipeline_status["history_messages"].append(status_message) + else: + logger.debug(status_message) + else: logger.error(f"Entity {entity_name} has no description") description = "(no description)" @@ -1458,17 +1461,20 @@ async def _merge_edges_then_upsert( ) # Log based on actual LLM usage - if already_fragment > 0 or llm_was_used: - 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 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 or llm_was_used: logger.info(status_message) if pipeline_status is not None and pipeline_status_lock is not None: async with pipeline_status_lock: pipeline_status["latest_message"] = status_message pipeline_status["history_messages"].append(status_message) + else: + logger.debug(status_message) + else: logger.error(f"Edge {src_id} - {tgt_id} has no description") description = "(no description)"