Compare commits
1 Commits
feat/reduc
...
release/v0
| Author | SHA1 | Date | |
|---|---|---|---|
| ffb1c212ea |
@ -1648,7 +1648,7 @@ func replaceRelatedWorkflowOrExternalResourceInWorkflowNodes(nodes []*vo.Node, r
|
||||
for _, node := range nodes {
|
||||
switch entity.IDStrToNodeType(node.Type) {
|
||||
case entity.NodeTypeSubWorkflow:
|
||||
if !hasWorkflowRelated {
|
||||
if !hasWorkflowRelated || node.Data.Inputs.SubWorkflow == nil {
|
||||
continue
|
||||
}
|
||||
workflowID, err := strconv.ParseInt(node.Data.Inputs.WorkflowID, 10, 64)
|
||||
@ -1660,7 +1660,7 @@ func replaceRelatedWorkflowOrExternalResourceInWorkflowNodes(nodes []*vo.Node, r
|
||||
node.Data.Inputs.WorkflowVersion = wf.Version
|
||||
}
|
||||
case entity.NodeTypePlugin:
|
||||
if !hasPluginRelated {
|
||||
if !hasPluginRelated || node.Data.Inputs.PluginAPIParam == nil {
|
||||
continue
|
||||
}
|
||||
apiParams := slices.ToMap(node.Data.Inputs.APIParams, func(e *vo.Param) (string, *vo.Param) {
|
||||
@ -1703,6 +1703,9 @@ func replaceRelatedWorkflowOrExternalResourceInWorkflowNodes(nodes []*vo.Node, r
|
||||
}
|
||||
|
||||
case entity.NodeTypeLLM:
|
||||
if node.Data.Inputs.LLM == nil {
|
||||
continue
|
||||
}
|
||||
if hasWorkflowRelated && node.Data.Inputs.FCParam != nil && node.Data.Inputs.FCParam.WorkflowFCParam != nil {
|
||||
for idx := range node.Data.Inputs.FCParam.WorkflowFCParam.WorkflowList {
|
||||
wf := node.Data.Inputs.FCParam.WorkflowFCParam.WorkflowList[idx]
|
||||
@ -1749,7 +1752,7 @@ func replaceRelatedWorkflowOrExternalResourceInWorkflowNodes(nodes []*vo.Node, r
|
||||
}
|
||||
|
||||
case entity.NodeTypeKnowledgeIndexer, entity.NodeTypeKnowledgeRetriever:
|
||||
if !hasKnowledgeRelated {
|
||||
if !hasKnowledgeRelated || node.Data.Inputs.Knowledge == nil {
|
||||
continue
|
||||
}
|
||||
datasetListInfoParam := node.Data.Inputs.DatasetParam[0]
|
||||
@ -1765,7 +1768,7 @@ func replaceRelatedWorkflowOrExternalResourceInWorkflowNodes(nodes []*vo.Node, r
|
||||
}
|
||||
|
||||
case entity.NodeTypeDatabaseCustomSQL, entity.NodeTypeDatabaseQuery, entity.NodeTypeDatabaseInsert, entity.NodeTypeDatabaseDelete, entity.NodeTypeDatabaseUpdate:
|
||||
if !hasDatabaseRelated {
|
||||
if !hasDatabaseRelated || node.Data.Inputs.DatabaseNode == nil {
|
||||
continue
|
||||
}
|
||||
dsList := node.Data.Inputs.DatabaseInfoList
|
||||
|
||||
Reference in New Issue
Block a user