gmakstutis/LightRAG
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix linting

Browse source
This commit is contained in:
yangdx 2025-08-14 13:03:23 +08:00
parent 772f981e7e
commit 3bba5fc506
2 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lightrag/api/routers/document_routes.py
View file

@ -1058,7 +1058,9 @@ async def run_scanning_process(
logger.info(f"Scanning process completed: {total_files} files Processed.") logger.info(f"Scanning process completed: {total_files} files Processed.")
else: else:
# No new files to index, check if there are any documents in the queue # No new files to index, check if there are any documents in the queue
logger.info("No upload file found, check if there are any documents in the queue...") logger.info(
"No upload file found, check if there are any documents in the queue..."
)
await rag.apipeline_process_enqueue_documents() await rag.apipeline_process_enqueue_documents()
except Exception as e: except Exception as e:

8
lightrag/lightrag.py
View file

@ -1131,7 +1131,9 @@ class LightRAG:
# Delete inconsistent document entries one by one # Delete inconsistent document entries one by one
if inconsistent_docs: if inconsistent_docs:
async with pipeline_status_lock: async with pipeline_status_lock:
summary_message = f"Inconsistent document entries found: {len(inconsistent_docs)}" summary_message = (
f"Inconsistent document entries found: {len(inconsistent_docs)}"
)
logger.info(summary_message) logger.info(summary_message)
pipeline_status["latest_message"] = summary_message pipeline_status["latest_message"] = summary_message
pipeline_status["history_messages"].append(summary_message) pipeline_status["history_messages"].append(summary_message)
@ -1159,9 +1161,7 @@ class LightRAG:
except Exception as e: except Exception as e:
# Log deletion failure # Log deletion failure
async with pipeline_status_lock: async with pipeline_status_lock:
error_message = ( error_message = f"Failed to delete entry: {doc_id} - {str(e)}"
f"Failed to delete entry: {doc_id} - {str(e)}"
)
logger.error(error_message) logger.error(error_message)
pipeline_status["latest_message"] = error_message pipeline_status["latest_message"] = error_message
pipeline_status["history_messages"].append(error_message) pipeline_status["history_messages"].append(error_message)