executeLoopNode 执行循环节点
(execution *WorkflowExecution, node *NodeDef, result *NodeResult)
| 683 | |
| 684 | // executeLoopNode 执行循环节点 |
| 685 | func (e *Engine) executeLoopNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error { |
| 686 | if node.Loop == nil { |
| 687 | return errors.New("loop node requires loop configuration") |
| 688 | } |
| 689 | |
| 690 | // TODO: 实现循环逻辑 |
| 691 | result.Outputs["loop_completed"] = true |
| 692 | return nil |
| 693 | } |
| 694 | |
| 695 | // executeParallelNode 执行并行节点 |
| 696 | func (e *Engine) executeParallelNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error { |