From 49d268d4a335014f46404348a5626dccc1caca8d Mon Sep 17 00:00:00 2001
From: jyong <718720800@qq.com>
Date: Wed, 3 Sep 2025 19:20:14 +0800
Subject: [PATCH] fix preview and recommend plugins

---
 .../workflow/nodes/datasource/datasource_node.py   | 12 ++----------
 api/core/workflow/workflow_entry.py                | 14 +++++++-------
 2 files changed, 9 insertions(+), 17 deletions(-)

diff --git a/api/core/workflow/nodes/datasource/datasource_node.py b/api/core/workflow/nodes/datasource/datasource_node.py
index 5dc89c23d7..9c450d6db0 100644
--- a/api/core/workflow/nodes/datasource/datasource_node.py
+++ b/api/core/workflow/nodes/datasource/datasource_node.py
@@ -111,15 +111,7 @@ class DatasourceNode(Node):
                 )
             )
 
-        # get parameters
-        datasource_parameters = datasource_runtime.entity.parameters
-
-        parameters_for_log = self._generate_parameters(
-            datasource_parameters=datasource_parameters,
-            variable_pool=variable_pool,
-            node_data=self._node_data,
-            for_log=True,
-        )
+        parameters_for_log = datasource_info
 
         try:
             datasource_provider_service = DatasourceProviderService()
@@ -213,7 +205,7 @@ class DatasourceNode(Node):
                             inputs=parameters_for_log,
                             metadata={WorkflowNodeExecutionMetadataKey.DATASOURCE_INFO: datasource_info},
                             outputs={
-                                "file_info": datasource_info,
+                                "file": datasource_info,
                                 "datasource_type": datasource_type,
                             },
                         )
diff --git a/api/core/workflow/workflow_entry.py b/api/core/workflow/workflow_entry.py
index 60b1948a27..414f3af8f9 100644
--- a/api/core/workflow/workflow_entry.py
+++ b/api/core/workflow/workflow_entry.py
@@ -184,13 +184,13 @@ class WorkflowEntry:
             variable_mapping=variable_mapping,
             user_inputs=user_inputs,
         )
-
-        cls.mapping_user_inputs_to_variable_pool(
-            variable_mapping=variable_mapping,
-            user_inputs=user_inputs,
-            variable_pool=variable_pool,
-            tenant_id=workflow.tenant_id,
-        )
+        if node_type != NodeType.DATASOURCE:
+            cls.mapping_user_inputs_to_variable_pool(
+                variable_mapping=variable_mapping,
+                user_inputs=user_inputs,
+                variable_pool=variable_pool,
+                tenant_id=workflow.tenant_id,
+            )
 
         try:
             # run node