Optimize logger info
This commit is contained in:
@@ -921,7 +921,7 @@ class LightRAG:
|
|||||||
)
|
)
|
||||||
pipeline_status["cur_batch"] = processed_count
|
pipeline_status["cur_batch"] = processed_count
|
||||||
|
|
||||||
log_message = f"Processing file {current_file_number}/{total_files}: {file_path}"
|
log_message = f"Extracting stage {current_file_number}/{total_files}: {file_path}"
|
||||||
logger.info(log_message)
|
logger.info(log_message)
|
||||||
pipeline_status["history_messages"].append(log_message)
|
pipeline_status["history_messages"].append(log_message)
|
||||||
log_message = f"Processing d-id: {doc_id}"
|
log_message = f"Processing d-id: {doc_id}"
|
||||||
|
@@ -529,7 +529,7 @@ async def merge_nodes_and_edges(
|
|||||||
async with graph_db_lock:
|
async with graph_db_lock:
|
||||||
async with pipeline_status_lock:
|
async with pipeline_status_lock:
|
||||||
log_message = (
|
log_message = (
|
||||||
f"Merging nodes/edges {current_file_number}/{total_files}: {file_path}"
|
f"Merging stage {current_file_number}/{total_files}: {file_path}"
|
||||||
)
|
)
|
||||||
logger.info(log_message)
|
logger.info(log_message)
|
||||||
pipeline_status["latest_message"] = log_message
|
pipeline_status["latest_message"] = log_message
|
||||||
|
Reference in New Issue
Block a user