From fede788356e1193538c25aaf4ff0dc7d2c425683 Mon Sep 17 00:00:00 2001 From: yongtenglei Date: Wed, 12 Nov 2025 11:20:31 +0800 Subject: [PATCH] clean --- api/db/services/document_service.py | 1 - rag/svr/task_executor.py | 3 --- 2 files changed, 4 deletions(-) diff --git a/api/db/services/document_service.py b/api/db/services/document_service.py index 3aca13afb..a64ae16de 100644 --- a/api/db/services/document_service.py +++ b/api/db/services/document_service.py @@ -698,7 +698,6 @@ class DocumentService(CommonService): for t in tsks: task_type = (t.task_type or "").lower() if task_type in PIPELINE_SPECIAL_PROGRESS_FREEZE_TASK_TYPES: - print("🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁🥁", flush=True) special_task_running = True if 0 <= t.progress < 1: finished = False diff --git a/rag/svr/task_executor.py b/rag/svr/task_executor.py index 7f47b71f2..5f56646ef 100644 --- a/rag/svr/task_executor.py +++ b/rag/svr/task_executor.py @@ -194,9 +194,6 @@ async def collect(): if msg.get("doc_id", "") in [GRAPH_RAPTOR_FAKE_DOC_ID, CANVAS_DEBUG_DOC_ID]: task = msg if task["task_type"] in ["graphrag", "raptor", "mindmap"]: - print(f"{PIPELINE_SPECIAL_PROGRESS_FREEZE_TASK_TYPES=}",flush=True) - print(f"should be one of ['graphrag', 'raptor', 'mindmap']: {task['task_type'] in ['graphrag', 'raptor', 'mindmap']}", flush=True) - print(f"double check: {task['task_type'] in PIPELINE_SPECIAL_PROGRESS_FREEZE_TASK_TYPES}", flush=True) task = TaskService.get_task(msg["id"], msg["doc_ids"]) if task: task["doc_id"] = msg["doc_id"]