opensource/dify
2
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-04-07 08:46:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix user_id missed

Browse Source
This commit is contained in:
jyong 2025-09-10 15:02:03 +08:00
parent f4abd3856a
commit 6103aa7830
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1312,11 +1312,16 @@ class RagPipelineService:
"uninstalled_recommended_plugins": uninstalled_plugin_list,
}
def get_datasource_plugins(self, pipeline_id: str, is_published: bool) -> list[dict]:
def get_datasource_plugins(self, dataset_id: str, is_published: bool) -> list[dict]:
"""
Get datasource plugins
"""
pipeline: Pipeline | None = db.session.query(Pipeline).filter(Pipeline.id == pipeline_id).first()
dataset: Dataset | None = db.session.query(Dataset).filter(Dataset.id == dataset_id).first()
if not dataset:
raise ValueError("Dataset not found")
pipeline: Pipeline | None = db.session.query(Pipeline).filter(Pipeline.id == dataset.pipeline_id).first()
if not pipeline:
raise ValueError("Pipeline not found")
workflow: Workflow | None = None
if is_published: