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

update

Browse source
This commit is contained in:
buua436 2025-12-09 18:51:11 +08:00
parent 2440939fa1
commit 9e9bbe6b6d
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
rag/svr/task_executor.py
View file

@ -305,7 +305,7 @@ async def build_chunks(task, progress_callback):
try: try:
await asyncio.gather(*tasks, return_exceptions=False) await asyncio.gather(*tasks, return_exceptions=False)
except Exception as e: except Exception as e:
logging.error("Saving chunk {}/{}/{} got exception".format(task["location"], task["name"], d["id"])) logging.error(f"MINIO PUT({task['name']}) got exception: {e}")
for t in tasks: for t in tasks:
t.cancel() t.cancel()
await asyncio.gather(*tasks, return_exceptions=True) await asyncio.gather(*tasks, return_exceptions=True)
@ -831,7 +831,7 @@ async def insert_es(task_id, task_tenant_id, task_dataset_id, chunks, progress_c
try: try:
await asyncio.gather(*tasks, return_exceptions=False) await asyncio.gather(*tasks, return_exceptions=False)
except Exception as e: except Exception as e:
logging.error(f"do_handle_task delete_image failed since task {task_id} is unknown.") logging.error(f"delete_image failed: {e}")
for t in tasks: for t in tasks:
t.cancel() t.cancel()
await asyncio.gather(*tasks, return_exceptions=True) await asyncio.gather(*tasks, return_exceptions=True)