yangdx
commited on
Commit
·
491cb6d
1
Parent(s):
beace6c
Shorten log message to fit in pipelinestatus UI
Browse files- lightrag/operate.py +2 -2
lightrag/operate.py
CHANGED
@@ -591,7 +591,7 @@ async def extract_entities(
|
|
591 |
processed_chunks += 1
|
592 |
entities_count = len(maybe_nodes)
|
593 |
relations_count = len(maybe_edges)
|
594 |
-
log_message = f"
|
595 |
logger.info(log_message)
|
596 |
if pipeline_status is not None:
|
597 |
async with pipeline_status_lock:
|
@@ -656,7 +656,7 @@ async def extract_entities(
|
|
656 |
pipeline_status["latest_message"] = log_message
|
657 |
pipeline_status["history_messages"].append(log_message)
|
658 |
|
659 |
-
log_message = f"Extracted {len(all_entities_data)} entities
|
660 |
logger.info(log_message)
|
661 |
if pipeline_status is not None:
|
662 |
async with pipeline_status_lock:
|
|
|
591 |
processed_chunks += 1
|
592 |
entities_count = len(maybe_nodes)
|
593 |
relations_count = len(maybe_edges)
|
594 |
+
log_message = f" Chk {processed_chunks}/{total_chunks}: extracted {entities_count} Ent + {relations_count} Rel (deduplicated)"
|
595 |
logger.info(log_message)
|
596 |
if pipeline_status is not None:
|
597 |
async with pipeline_status_lock:
|
|
|
656 |
pipeline_status["latest_message"] = log_message
|
657 |
pipeline_status["history_messages"].append(log_message)
|
658 |
|
659 |
+
log_message = f"Extracted {len(all_entities_data)} entities + {len(all_relationships_data)} relationships (deduplicated)"
|
660 |
logger.info(log_message)
|
661 |
if pipeline_status is not None:
|
662 |
async with pipeline_status_lock:
|