From b8ef1d958524941151a1c50679c3b26f1c26eb40 Mon Sep 17 00:00:00 2001 From: jyong <718720800@qq.com> Date: Thu, 5 Jun 2025 16:43:47 +0800 Subject: [PATCH] r2 --- .../console/datasets/rag_pipeline/rag_pipeline_workflow.py | 1 + api/services/rag_pipeline/rag_pipeline.py | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/api/controllers/console/datasets/rag_pipeline/rag_pipeline_workflow.py b/api/controllers/console/datasets/rag_pipeline/rag_pipeline_workflow.py index b66a747121..7710a6770b 100644 --- a/api/controllers/console/datasets/rag_pipeline/rag_pipeline_workflow.py +++ b/api/controllers/console/datasets/rag_pipeline/rag_pipeline_workflow.py @@ -39,6 +39,7 @@ from libs.helper import TimestampField, uuid_value from libs.login import current_user, login_required from models.account import Account from models.dataset import Pipeline +from models.model import EndUser from services.errors.app import WorkflowHashNotEqualError from services.errors.llm import InvokeRateLimitError from services.rag_pipeline.pipeline_generate_service import PipelineGenerateService diff --git a/api/services/rag_pipeline/rag_pipeline.py b/api/services/rag_pipeline/rag_pipeline.py index 5541349edb..79925a1c1b 100644 --- a/api/services/rag_pipeline/rag_pipeline.py +++ b/api/services/rag_pipeline/rag_pipeline.py @@ -676,7 +676,7 @@ class RagPipelineService: item["variable"]: item for item in variables } else: - variables_map = {} + return [] datasource_parameters = datasource_node_data.get("datasource_parameters", {}) user_input_variables = [] for key, value in datasource_parameters.items(): @@ -708,7 +708,7 @@ class RagPipelineService: item["variable"]: item for item in variables } else: - variables = {} + return [] datasource_parameters = datasource_node_data.get("datasource_parameters", {}) user_input_variables = []