findNode 查找节点
(def *WorkflowDefinition, nodeID string)
| 725 | |
| 726 | // findNode 查找节点 |
| 727 | func (e *Engine) findNode(def *WorkflowDefinition, nodeID string) *NodeDef { |
| 728 | for _, node := range def.Nodes { |
| 729 | if node.ID == nodeID { |
| 730 | return &node |
| 731 | } |
| 732 | } |
| 733 | return nil |
| 734 | } |
| 735 | |
| 736 | // findNextNodes 查找下一批节点 |
| 737 | func (e *Engine) findNextNodes(execution *WorkflowExecution, currentNodes []string) []string { |