From bac1ac13b6c039988a0471e203616081c18699bb Mon Sep 17 00:00:00 2001 From: Kevin Hu Date: Thu, 20 Nov 2025 13:49:21 +0800 Subject: [PATCH] Fix: none obj --- api/apps/sdk/dify_retrieval.py | 2 +- api/apps/sdk/doc.py | 2 +- api/db/services/canvas_service.py | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/api/apps/sdk/dify_retrieval.py b/api/apps/sdk/dify_retrieval.py index 8ea24a6d5..55ea54faf 100644 --- a/api/apps/sdk/dify_retrieval.py +++ b/api/apps/sdk/dify_retrieval.py @@ -120,7 +120,7 @@ async def retrieval(tenant_id): retrieval_setting = req.get("retrieval_setting", {}) similarity_threshold = float(retrieval_setting.get("score_threshold", 0.0)) top = int(retrieval_setting.get("top_k", 1024)) - metadata_condition = req.get("metadata_condition", {}) + metadata_condition = req.get("metadata_condition", {}) or {} metas = DocumentService.get_meta_by_kbs([kb_id]) doc_ids = [] diff --git a/api/apps/sdk/doc.py b/api/apps/sdk/doc.py index f4653aafc..84300ac3c 100644 --- a/api/apps/sdk/doc.py +++ b/api/apps/sdk/doc.py @@ -1442,7 +1442,7 @@ async def retrieval_test(tenant_id): if doc_id not in doc_ids_list: return get_error_data_result(f"The datasets don't own the document {doc_id}") if not doc_ids: - metadata_condition = req.get("metadata_condition", {}) + metadata_condition = req.get("metadata_condition", {}) or {} metas = DocumentService.get_meta_by_kbs(kb_ids) doc_ids = meta_filter(metas, convert_conditions(metadata_condition), metadata_condition.get("logic", "and")) similarity_threshold = float(req.get("similarity_threshold", 0.2)) diff --git a/api/db/services/canvas_service.py b/api/db/services/canvas_service.py index db8e16068..b5f3dfeed 100644 --- a/api/db/services/canvas_service.py +++ b/api/db/services/canvas_service.py @@ -219,7 +219,7 @@ def completion(tenant_id, agent_id, session_id=None, **kwargs): "id": message_id }) txt = "" - for ans in canvas.run(query=query, files=files, user_id=user_id, inputs=inputs): + async for ans in canvas.run(query=query, files=files, user_id=user_id, inputs=inputs): ans["session_id"] = session_id if ans["event"] == "message": txt += ans["data"]["content"]