From f4abd3856a0254b36c4eece30ffdacd3d95350c9 Mon Sep 17 00:00:00 2001
From: jyong <718720800@qq.com>
Date: Wed, 10 Sep 2025 14:13:44 +0800
Subject: [PATCH] fix user_id missed

---
 api/services/rag_pipeline/rag_pipeline.py | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/api/services/rag_pipeline/rag_pipeline.py b/api/services/rag_pipeline/rag_pipeline.py
index 709782a123..cc3a19a2a5 100644
--- a/api/services/rag_pipeline/rag_pipeline.py
+++ b/api/services/rag_pipeline/rag_pipeline.py
@@ -1354,11 +1354,12 @@ class RagPipelineService:
                     user_input_variables.append(value)
 
                 datasource_plugins.append({
+                    "node_id": datasource_node.get("id"),
                     "plugin_id": datasource_node_data.get("plugin_id"),
                     "provider_name": datasource_node_data.get("provider_name"),
-                    "datasource_name": datasource_node_data.get("datasource_name"),
-                    "datasource_configurations": datasource_node_data.get("datasource_configurations"),
-                    "plugin_unique_identifier": datasource_node_data.get("plugin_unique_identifier"),
+                    "provider_type": datasource_node_data.get("provider_type"),
+                    "title": datasource_node_data.get("title"),
+                    "user_input_variables": user_input_variables,
                 })
 
         return datasource_plugins