diff --git a/lightrag/operate.py b/lightrag/operate.py index 083a8c65..5da02683 100644 --- a/lightrag/operate.py +++ b/lightrag/operate.py @@ -591,7 +591,7 @@ async def extract_entities( processed_chunks += 1 entities_count = len(maybe_nodes) relations_count = len(maybe_edges) - log_message = f" Chunk {processed_chunks}/{total_chunks}: extracted {entities_count} entities and {relations_count} relationships (deduplicated)" + log_message = f" Chk {processed_chunks}/{total_chunks}: extracted {entities_count} Ent + {relations_count} Rel (deduplicated)" logger.info(log_message) if pipeline_status is not None: async with pipeline_status_lock: @@ -656,7 +656,7 @@ async def extract_entities( pipeline_status["latest_message"] = log_message pipeline_status["history_messages"].append(log_message) - log_message = f"Extracted {len(all_entities_data)} entities and {len(all_relationships_data)} relationships (deduplicated)" + log_message = f"Extracted {len(all_entities_data)} entities + {len(all_relationships_data)} relationships (deduplicated)" logger.info(log_message) if pipeline_status is not None: async with pipeline_status_lock: