executeMergeNode 执行合并节点
(execution *WorkflowExecution, node *NodeDef, result *NodeResult)
| 705 | |
| 706 | // executeMergeNode 执行合并节点 |
| 707 | func (e *Engine) executeMergeNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error { |
| 708 | // 合并节点主要用于汇聚多个分支 |
| 709 | result.Outputs["merge_completed"] = true |
| 710 | return nil |
| 711 | } |
| 712 | |
| 713 | // 辅助方法 |
| 714 |