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

Change document deletion warnings to info level logging

Browse source
This commit is contained in:
yangdx 2025-08-20 03:28:42 +08:00
parent ac9647d117
commit 485c4b7de7
1 changed files with 11 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
lightrag/lightrag.py
View file

@ -2219,16 +2219,20 @@ class LightRAG:
doc_status = doc_status_data.get("status") doc_status = doc_status_data.get("status")
if doc_status != DocStatus.PROCESSED: if doc_status != DocStatus.PROCESSED:
if doc_status == DocStatus.PENDING: if doc_status == DocStatus.PENDING:
warning_msg = f"WARNING: Deleting {doc_id} {file_path}(previous status: PENDING)" warning_msg = (
f"Deleting {doc_id} {file_path}(previous status: PENDING)"
)
elif doc_status == DocStatus.PROCESSING: elif doc_status == DocStatus.PROCESSING:
warning_msg = f"WARNING: Deleting {doc_id} {file_path}(previous status: PROCESSING)" warning_msg = (
f"Deleting {doc_id} {file_path}(previous status: PROCESSING)"
)
elif doc_status == DocStatus.FAILED: elif doc_status == DocStatus.FAILED:
warning_msg = f"WARNING: Deleting {doc_id} {file_path}(previous status: FAILED)" warning_msg = (
f"Deleting {doc_id} {file_path}(previous status: FAILED)"
)
else: else:
warning_msg = f"WARNING: Deleting {doc_id} {file_path}(previous status: {doc_status.value})" warning_msg = f"Deleting {doc_id} {file_path}(previous status: {doc_status.value})"
logger.info(warning_msg)
logger.warning(warning_msg)
# Update pipeline status for monitoring # Update pipeline status for monitoring
async with pipeline_status_lock: async with pipeline_status_lock:
pipeline_status["latest_message"] = warning_msg pipeline_status["latest_message"] = warning_msg