diff --git a/rag/svr/task_executor.py b/rag/svr/task_executor.py index cae5bd52e..0094c081c 100644 --- a/rag/svr/task_executor.py +++ b/rag/svr/task_executor.py @@ -305,7 +305,7 @@ async def build_chunks(task, progress_callback): try: await asyncio.gather(*tasks, return_exceptions=False) 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: t.cancel() 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: await asyncio.gather(*tasks, return_exceptions=False) 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: t.cancel() await asyncio.gather(*tasks, return_exceptions=True)