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

Add error handling with chunk ID prefixing in entity extraction

Browse source
This commit is contained in:
yangdx 2025-09-16 13:41:49 +08:00
parent 5f45ff56be
commit ecaee43788
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lightrag/operate.py
View file

@ -2179,7 +2179,12 @@ async def extract_entities(
async def _process_with_semaphore(chunk): async def _process_with_semaphore(chunk):
async with semaphore: async with semaphore:
return await _process_single_content(chunk) try:
return await _process_single_content(chunk)
except Exception as e:
chunk_id = chunk[0] # Extract chunk_id from chunk[0]
prefixed_exception = create_prefixed_exception(e, chunk_id)
raise prefixed_exception from e
tasks = [] tasks = []
for c in ordered_chunks: for c in ordered_chunks: