executeEndNode 执行结束节点
(execution *WorkflowExecution, node *NodeDef, result *NodeResult)
| 611 | |
| 612 | // executeEndNode 执行结束节点 |
| 613 | func (e *Engine) executeEndNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error { |
| 614 | // 收集工作流输出 |
| 615 | maps.Copy(execution.Context.Outputs, execution.Context.Variables) |
| 616 | |
| 617 | result.Outputs["completed_at"] = time.Now() |
| 618 | result.Outputs["outputs"] = execution.Context.Outputs |
| 619 | return nil |
| 620 | } |
| 621 | |
| 622 | // executeTaskNode 执行任务节点 |
| 623 | func (e *Engine) executeTaskNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error { |