diff --git a/lightrag/lightrag.py b/lightrag/lightrag.py
index d52bb01c..d89e9052 100644
--- a/lightrag/lightrag.py
+++ b/lightrag/lightrag.py
@@ -921,7 +921,7 @@ class LightRAG:
                                 )
                                 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)
                                 pipeline_status["history_messages"].append(log_message)
                                 log_message = f"Processing d-id: {doc_id}"
diff --git a/lightrag/operate.py b/lightrag/operate.py
index 74d8e1e4..14bcdae2 100644
--- a/lightrag/operate.py
+++ b/lightrag/operate.py
@@ -529,7 +529,7 @@ async def merge_nodes_and_edges(
     async with graph_db_lock:
         async with pipeline_status_lock:
             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)
             pipeline_status["latest_message"] = log_message