From 4403a26f37ae1a5f63114c352049454b394f86a0 Mon Sep 17 00:00:00 2001
From: jyong <718720800@qq.com>
Date: Wed, 27 Aug 2025 20:44:14 +0800
Subject: [PATCH] merge new graph engine

---
 api/core/workflow/nodes/datasource/datasource_node.py           | 2 +-
 api/core/workflow/nodes/knowledge_index/knowledge_index_node.py | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/api/core/workflow/nodes/datasource/datasource_node.py b/api/core/workflow/nodes/datasource/datasource_node.py
index 5fb199558d..1ccb062cd5 100644
--- a/api/core/workflow/nodes/datasource/datasource_node.py
+++ b/api/core/workflow/nodes/datasource/datasource_node.py
@@ -43,7 +43,7 @@ class DatasourceNode(Node):
     """
 
     _node_data: DatasourceNodeData
-    _node_type = NodeType.DATASOURCE
+    node_type = NodeType.DATASOURCE
 
     def init_node_data(self, data: Mapping[str, Any]) -> None:
         self._node_data = DatasourceNodeData.model_validate(data)
diff --git a/api/core/workflow/nodes/knowledge_index/knowledge_index_node.py b/api/core/workflow/nodes/knowledge_index/knowledge_index_node.py
index 2880518b94..2efcb69445 100644
--- a/api/core/workflow/nodes/knowledge_index/knowledge_index_node.py
+++ b/api/core/workflow/nodes/knowledge_index/knowledge_index_node.py
@@ -36,7 +36,7 @@ default_retrieval_model = {
 
 class KnowledgeIndexNode(Node):
     _node_data: KnowledgeIndexNodeData
-    _node_type = NodeType.KNOWLEDGE_INDEX
+    node_type = NodeType.KNOWLEDGE_INDEX
 
     def init_node_data(self, data: Mapping[str, Any]) -> None:
         self._node_data = KnowledgeIndexNodeData.model_validate(data)