executeStartNode 执行开始节点
(execution *WorkflowExecution, node *NodeDef, result *NodeResult)
| 604 | |
| 605 | // executeStartNode 执行开始节点 |
| 606 | func (e *Engine) executeStartNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error { |
| 607 | // 开始节点主要是初始化 |
| 608 | result.Outputs["started_at"] = time.Now() |
| 609 | return nil |
| 610 | } |
| 611 | |
| 612 | // executeEndNode 执行结束节点 |
| 613 | func (e *Engine) executeEndNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error { |