github
/
allinssl
mirror of https://github.com/allinssl/allinssl
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

修复工作流中有并行分支时panic

1.0.6
v-me-50 2025-06-23 11:08:32 +08:00
parent 6d1b05e7c0
commit f499afc060
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
backend/internal/workflow/workflow.go
View File

@ -245,6 +245,7 @@ func RunNode(node *WorkflowNode, ctx *ExecutionContext) error {
var wg sync.WaitGroup var wg sync.WaitGroup
errChan := make(chan error, len(node.ConditionNodes)) errChan := make(chan error, len(node.ConditionNodes))
for _, branch := range node.ConditionNodes { for _, branch := range node.ConditionNodes {
branch.ChildNode.Config["fromNodeData"] = node.Config["fromNodeData"]
wg.Add(1) wg.Add(1)
go func(node *WorkflowNode) { go func(node *WorkflowNode) {
defer wg.Done() defer wg.Done()
@ -286,6 +287,9 @@ func RunNode(node *WorkflowNode, ctx *ExecutionContext) error {
} }
if node.ChildNode != nil { if node.ChildNode != nil {
if node.ChildNode.Config == nil {
node.ChildNode.Config = make(map[string]any)
}
fromNodeData, ok := ctx.GetOutput(node.Id) fromNodeData, ok := ctx.GetOutput(node.Id)
if ok && fromNodeData != nil && node.ChildNode.Config["fromNodeData"] == nil { if ok && fromNodeData != nil && node.ChildNode.Config["fromNodeData"] == nil {
node.ChildNode.Config["fromNodeData"] = fromNodeData node.ChildNode.Config["fromNodeData"] = fromNodeData