Ensure branches execute independently without affecting each other

2024-12-02 08:54:25 +08:00
parent 124af0b76d
commit a5d097e860
1 changed files with 1 additions and 1 deletions
--- a/internal/workflow/node-processor/workflow_processor.go
+++ b/internal/workflow/node-processor/workflow_processor.go
@@ -33,7 +33,7 @@ func (w *workflowProcessor) runNode(ctx context.Context, node *domain.WorkflowNo
 		if current.Type == domain.WorkflowNodeTypeBranch {
 			for _, branch := range current.Branches {
 				if err := w.runNode(ctx, &branch); err != nil {
-					return err
+					continue
 				}
 			}
 		}