yujunjun/dify
1
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2025-11-13 17:59:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

r2

Browse Source
This commit is contained in:
jyong 2025-06-05 16:43:47 +08:00
parent c084b57933
commit b8ef1d9585
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
api/controllers/console/datasets/rag_pipeline/rag_pipeline_workflow.py
View File

@ -39,6 +39,7 @@ from libs.helper import TimestampField, uuid_value
from libs.login import current_user, login_required from libs.login import current_user, login_required
from models.account import Account from models.account import Account
from models.dataset import Pipeline from models.dataset import Pipeline
from models.model import EndUser
from services.errors.app import WorkflowHashNotEqualError from services.errors.app import WorkflowHashNotEqualError
from services.errors.llm import InvokeRateLimitError from services.errors.llm import InvokeRateLimitError
from services.rag_pipeline.pipeline_generate_service import PipelineGenerateService from services.rag_pipeline.pipeline_generate_service import PipelineGenerateService

4
api/services/rag_pipeline/rag_pipeline.py
View File

@ -676,7 +676,7 @@ class RagPipelineService:
item["variable"]: item for item in variables item["variable"]: item for item in variables
} }
else: else:
variables_map = {} return []
datasource_parameters = datasource_node_data.get("datasource_parameters", {}) datasource_parameters = datasource_node_data.get("datasource_parameters", {})
user_input_variables = [] user_input_variables = []
for key, value in datasource_parameters.items(): for key, value in datasource_parameters.items():
@ -708,7 +708,7 @@ class RagPipelineService:
item["variable"]: item for item in variables item["variable"]: item for item in variables
} }
else: else:
variables = {} return []
datasource_parameters = datasource_node_data.get("datasource_parameters", {}) datasource_parameters = datasource_node_data.get("datasource_parameters", {})
user_input_variables = [] user_input_variables = []