executeParallelNode 执行并行节点
(execution *WorkflowExecution, node *NodeDef, result *NodeResult)
| 694 | |
| 695 | // executeParallelNode 执行并行节点 |
| 696 | func (e *Engine) executeParallelNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error { |
| 697 | if node.Parallel == nil { |
| 698 | return errors.New("parallel node requires parallel configuration") |
| 699 | } |
| 700 | |
| 701 | // TODO: 实现并行逻辑 |
| 702 | result.Outputs["parallel_completed"] = true |
| 703 | return nil |
| 704 | } |
| 705 | |
| 706 | // executeMergeNode 执行合并节点 |
| 707 | func (e *Engine) executeMergeNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error { |