diff --git a/api/core/workflow/nodes/datasource/datasource_node.py b/api/core/workflow/nodes/datasource/datasource_node.py
index de2d03975a..2b3741c543 100644
--- a/api/core/workflow/nodes/datasource/datasource_node.py
+++ b/api/core/workflow/nodes/datasource/datasource_node.py
@@ -73,7 +73,7 @@ class DatasourceNode(Node):
         Run the datasource node
         """
 
-        node_data = cast(DatasourceNodeData, self._node_data)
+        node_data = self._node_data
         variable_pool = self.graph_runtime_state.variable_pool
         datasource_type = variable_pool.get(["sys", SystemVariableKey.DATASOURCE_TYPE.value])
         if not datasource_type:
@@ -109,11 +109,7 @@ class DatasourceNode(Node):
 
         # get parameters
         datasource_parameters = datasource_runtime.entity.parameters
-        parameters = self._generate_parameters(
-            datasource_parameters=datasource_parameters,
-            variable_pool=variable_pool,
-            node_data=self._node_data,
-        )
+
         parameters_for_log = self._generate_parameters(
             datasource_parameters=datasource_parameters,
             variable_pool=variable_pool,
diff --git a/api/services/datasource_provider_service.py b/api/services/datasource_provider_service.py
index 8d536d2030..41884661b2 100644
--- a/api/services/datasource_provider_service.py
+++ b/api/services/datasource_provider_service.py
@@ -848,7 +848,7 @@ class DatasourceProviderService:
                         else None,
                     }
                 )
-            return datasource_credentials
+        return datasource_credentials
 
     def get_real_datasource_credentials(self, tenant_id: str, provider: str, plugin_id: str) -> list[dict]:
         """