feat: knowledge workflow

Author: shaohuzhang1

apps/application/flow/step_node/__init__.py

@@ -50,13 +50,9 @@
              BaseIntentNode, BaseLoopNode, BaseLoopStartStepNode,
              BaseLoopContinueNode,
              BaseLoopBreakNode, BaseVariableSplittingNode, BaseParameterExtractionNode, BaseVariableAggregationNode,
-<<<<<<< Updated upstream
-             BaseDataSourceLocalNode,BaseDataSourceWebNode,BaseKnowledgeWriteNode]
-=======
-             BaseDataSourceLocalNode, BaseDataSourceWebNode]
+             BaseDataSourceLocalNode, BaseDataSourceWebNode, BaseKnowledgeWriteNode]
 
 node_map = {n.type: {w: n for w in n.support} for n in node_list}
->>>>>>> Stashed changes
 
 
 def get_node(node_type, workflow_model):

apps/application/flow/step_node/knowledge_write_node/i_knowledge_write_node.py

@@ -11,28 +11,25 @@
 from django.utils.translation import gettext_lazy as _
 from rest_framework import serializers
 
+from application.flow.common import WorkflowMode
 from application.flow.i_step_node import INode, NodeResult
 
 
-
 class KnowledgeWriteNodeParamSerializer(serializers.Serializer):
     paragraph_list = serializers.ListField(required=True, label=_("Paragraph list"))
     chunk_length = serializers.CharField(required=True, label=_("Child chunk length"))
 
 
-
-
 class IKnowledgeWriteNode(INode):
 
     def get_node_params_serializer_class(self) -> Type[serializers.Serializer]:
         return KnowledgeWriteNodeParamSerializer
 
-
     def _run(self):
         return self.execute(**self.node_params_serializer.data, **self.flow_params_serializer.data)
 
     def execute(self, paragraph_list, chunk_length, **kwargs) -> NodeResult:
         pass
 
     type = 'knowledge-write-node'
-
+    support = [WorkflowMode.KNOWLEDGE]