Compare commits

..

1 Commits

Author SHA1 Message Date
ffb1c212ea fix: app workflow publish panic (#719)
(cherry picked from commit 708a6ed0c0)
2025-08-13 14:06:13 +08:00

View File

@ -1648,7 +1648,7 @@ func replaceRelatedWorkflowOrExternalResourceInWorkflowNodes(nodes []*vo.Node, r
for _, node := range nodes { for _, node := range nodes {
switch entity.IDStrToNodeType(node.Type) { switch entity.IDStrToNodeType(node.Type) {
case entity.NodeTypeSubWorkflow: case entity.NodeTypeSubWorkflow:
if !hasWorkflowRelated { if !hasWorkflowRelated || node.Data.Inputs.SubWorkflow == nil {
continue continue
} }
workflowID, err := strconv.ParseInt(node.Data.Inputs.WorkflowID, 10, 64) 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 node.Data.Inputs.WorkflowVersion = wf.Version
} }
case entity.NodeTypePlugin: case entity.NodeTypePlugin:
if !hasPluginRelated { if !hasPluginRelated || node.Data.Inputs.PluginAPIParam == nil {
continue continue
} }
apiParams := slices.ToMap(node.Data.Inputs.APIParams, func(e *vo.Param) (string, *vo.Param) { 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: case entity.NodeTypeLLM:
if node.Data.Inputs.LLM == nil {
continue
}
if hasWorkflowRelated && node.Data.Inputs.FCParam != nil && node.Data.Inputs.FCParam.WorkflowFCParam != nil { if hasWorkflowRelated && node.Data.Inputs.FCParam != nil && node.Data.Inputs.FCParam.WorkflowFCParam != nil {
for idx := range node.Data.Inputs.FCParam.WorkflowFCParam.WorkflowList { for idx := range node.Data.Inputs.FCParam.WorkflowFCParam.WorkflowList {
wf := node.Data.Inputs.FCParam.WorkflowFCParam.WorkflowList[idx] wf := node.Data.Inputs.FCParam.WorkflowFCParam.WorkflowList[idx]
@ -1749,7 +1752,7 @@ func replaceRelatedWorkflowOrExternalResourceInWorkflowNodes(nodes []*vo.Node, r
} }
case entity.NodeTypeKnowledgeIndexer, entity.NodeTypeKnowledgeRetriever: case entity.NodeTypeKnowledgeIndexer, entity.NodeTypeKnowledgeRetriever:
if !hasKnowledgeRelated { if !hasKnowledgeRelated || node.Data.Inputs.Knowledge == nil {
continue continue
} }
datasetListInfoParam := node.Data.Inputs.DatasetParam[0] 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: case entity.NodeTypeDatabaseCustomSQL, entity.NodeTypeDatabaseQuery, entity.NodeTypeDatabaseInsert, entity.NodeTypeDatabaseDelete, entity.NodeTypeDatabaseUpdate:
if !hasDatabaseRelated { if !hasDatabaseRelated || node.Data.Inputs.DatabaseNode == nil {
continue continue
} }
dsList := node.Data.Inputs.DatabaseInfoList dsList := node.Data.Inputs.DatabaseInfoList