Method findNode

pkg/workflow/actor_engine.go:598–605

(def *WorkflowDefinition, nodeID string)

}

func (c *CoordinatorActor) findNode(def *WorkflowDefinition, nodeID string) *NodeDef {
	for _, node := range def.Nodes {
		if node.ID == nodeID {
			return &node
		}
	}
	return nil
}

func (c *CoordinatorActor) findNextNodes(execution *WorkflowExecution, currentNodes []string) []string {
	var nextNodes []string