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

clean

Browse source
This commit is contained in:
yongtenglei 2025-11-12 11:20:31 +08:00
parent 78d55af843
commit fede788356
2 changed files with 0 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
api/db/services/document_service.py
View file

@ -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

3
rag/svr/task_executor.py
View file

@ -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"]