From b8bb90cda4c36740ecd97eba2bfd3c1f6a8bf631 Mon Sep 17 00:00:00 2001 From: zxstty Date: Fri, 13 Jun 2025 14:48:01 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=96=87=E6=A1=A3=E8=A7=A3?= =?UTF-8?q?=E6=9E=90=E7=9A=84=E5=86=97=E4=BD=99=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- data_chain/apps/base/task/worker/parse_document_worker.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/data_chain/apps/base/task/worker/parse_document_worker.py b/data_chain/apps/base/task/worker/parse_document_worker.py index 989de81..6920919 100644 --- a/data_chain/apps/base/task/worker/parse_document_worker.py +++ b/data_chain/apps/base/task/worker/parse_document_worker.py @@ -554,8 +554,6 @@ class ParseDocumentWorker(BaseWorker): return None await DocumentManager.update_document_by_doc_id(task_entity.op_id, {"status": DocumentStatus.IDLE.value}) if task_entity.status == TaskStatus.PENDING.value or task_entity.status == TaskStatus.RUNNING.value or task_entity.status == TaskStatus.FAILED.value: - if task_entity.status == TaskStatus.RUNNING.value or task_entity.status == TaskStatus.FAILED.value: - await TaskManager.update_task_by_id(task_id, {"status": TaskStatus.CANCLED.value}) await DocumentManager.update_document_by_doc_id(task_entity.op_id, {"abstract": "", "abstract_vector": None}) await ImageManager.update_images_by_doc_id(task_entity.op_id, {"status": ImageStatus.DELETED.value}) await ChunkManager.update_chunk_by_doc_id(task_entity.op_id, {"status": ChunkStatus.DELETED.value}) -- Gitee