diff --git a/lightrag/api/__init__.py b/lightrag/api/__init__.py index d512d983..952266f6 100644 --- a/lightrag/api/__init__.py +++ b/lightrag/api/__init__.py @@ -1 +1 @@ -__api_version__ = "0177" +__api_version__ = "0178" diff --git a/lightrag/api/routers/document_routes.py b/lightrag/api/routers/document_routes.py index c8b74a7d..1e21aa4f 100644 --- a/lightrag/api/routers/document_routes.py +++ b/lightrag/api/routers/document_routes.py @@ -866,7 +866,7 @@ async def background_delete_documents( if pipeline_status.get("busy", False): logger.warning("Error: Unexpected pipeline busy state, aborting deletion.") return # Abort deletion operation - + # Set pipeline status to busy for deletion pipeline_status.update( { @@ -982,14 +982,16 @@ async def background_delete_documents( completion_msg = f"Deletion completed: {len(successful_deletions)} successful, {len(failed_deletions)} failed" pipeline_status["latest_message"] = completion_msg pipeline_status["history_messages"].append(completion_msg) - + # Check if there are pending document indexing requests has_pending_request = pipeline_status.get("request_pending", False) # If there are pending requests, start document processing pipeline if has_pending_request: try: - logger.info("Processing pending document indexing requests after deletion") + logger.info( + "Processing pending document indexing requests after deletion" + ) await rag.apipeline_process_enqueue_documents() except Exception as e: logger.error(f"Error processing pending documents after deletion: {e}")