修复当出现异常时,会导致更新数据卡死的bug
Browse files- lightrag/lightrag.py +2 -3
lightrag/lightrag.py
CHANGED
|
@@ -469,9 +469,8 @@ class LightRAG:
|
|
| 469 |
error_msg = f"Failed to process document {doc_id}: {str(e)}\n{traceback.format_exc()}"
|
| 470 |
logger.error(error_msg)
|
| 471 |
continue
|
| 472 |
-
|
| 473 |
-
|
| 474 |
-
# Ensure all indexes are updated after each document
|
| 475 |
await self._insert_done()
|
| 476 |
|
| 477 |
def insert_custom_chunks(self, full_text: str, text_chunks: list[str]):
|
|
|
|
| 469 |
error_msg = f"Failed to process document {doc_id}: {str(e)}\n{traceback.format_exc()}"
|
| 470 |
logger.error(error_msg)
|
| 471 |
continue
|
| 472 |
+
else:
|
| 473 |
+
# Only update index when processing succeeds
|
|
|
|
| 474 |
await self._insert_done()
|
| 475 |
|
| 476 |
def insert_custom_chunks(self, full_text: str, text_chunks: list[str]):
|