yujunjun/LightRAG
1
0
Fork 0
mirror of https://github.com/HKUDS/LightRAG.git synced 2025-11-11 15:23:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Bump api version to 0178

Browse Source
This commit is contained in:
yangdx 2025-07-03 21:37:47 +08:00
parent 05231233f1
commit 67f51597c2
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lightrag/api/__init__.py
View File

@ -1 +1 @@
__api_version__ = "0177" __api_version__ = "0178"

8
lightrag/api/routers/document_routes.py
View File

@ -866,7 +866,7 @@ async def background_delete_documents(
if pipeline_status.get("busy", False): if pipeline_status.get("busy", False):
logger.warning("Error: Unexpected pipeline busy state, aborting deletion.") logger.warning("Error: Unexpected pipeline busy state, aborting deletion.")
return # Abort deletion operation return # Abort deletion operation
# Set pipeline status to busy for deletion # Set pipeline status to busy for deletion
pipeline_status.update( 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" completion_msg = f"Deletion completed: {len(successful_deletions)} successful, {len(failed_deletions)} failed"
pipeline_status["latest_message"] = completion_msg pipeline_status["latest_message"] = completion_msg
pipeline_status["history_messages"].append(completion_msg) pipeline_status["history_messages"].append(completion_msg)
# Check if there are pending document indexing requests # Check if there are pending document indexing requests
has_pending_request = pipeline_status.get("request_pending", False) has_pending_request = pipeline_status.get("request_pending", False)
# If there are pending requests, start document processing pipeline # If there are pending requests, start document processing pipeline
if has_pending_request: if has_pending_request:
try: 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() await rag.apipeline_process_enqueue_documents()
except Exception as e: except Exception as e:
logger.error(f"Error processing pending documents after deletion: {e}") logger.error(f"Error processing pending documents after deletion: {e}")