diff --git a/lightrag/api/routers/document_routes.py b/lightrag/api/routers/document_routes.py
index 7f092440..c1752e06 100644
--- a/lightrag/api/routers/document_routes.py
+++ b/lightrag/api/routers/document_routes.py
@@ -1154,7 +1154,7 @@ async def pipeline_enqueue_file(
                     content, file_paths=file_path.name, track_id=track_id
                 )
 
-                logger.info(f"Successfully fetched and enqueued file: {file_path.name}")
+                logger.info(f"Successfully extracted and enqueued file: {file_path.name}")
 
                 # Move file to __enqueued__ directory after enqueuing
                 try:
diff --git a/lightrag/lightrag.py b/lightrag/lightrag.py
index 7ff0bb54..55067b59 100644
--- a/lightrag/lightrag.py
+++ b/lightrag/lightrag.py
@@ -1330,7 +1330,7 @@ class LightRAG:
             # Process documents until no more documents or requests
             while True:
                 if not to_process_docs:
-                    log_message = "All documents have been processed or are duplicates"
+                    log_message = "All enqueued documents have been processed"
                     logger.info(log_message)
                     pipeline_status["latest_message"] = log_message
                     pipeline_status["history_messages"].append(log_message)