Method executeNodes

pkg/workflow/actor_engine.go:344–378

executeNodes 执行节点列表

(execution *WorkflowExecution, state *workflowState, nodeIDs []string)

// executeNodes 执行节点列表
func (c *CoordinatorActor) executeNodes(execution *WorkflowExecution, state *workflowState, nodeIDs []string) error {
	for _, nodeID := range nodeIDs {
		node := c.findNode(execution.Definition, nodeID)
		if node == nil {
			return fmt.Errorf("node not found: %s", nodeID)
		}

		// 根据节点类型执行
		switch node.Type {
		case NodeTypeTask:
			if err := c.executeTaskNodeWithActor(execution, state, node); err != nil {
				return err
			}
		case NodeTypeParallel:
			if err := c.executeParallelNodeWithActors(execution, state, node); err != nil {
				return err
			}
		default:
			// 使用原有引擎处理其他类型
			if !c.engine.executeNode(execution, nodeID) {
				return fmt.Errorf("node execution failed: %s", nodeID)
			}
		}

		execution.CompletedNodes[nodeID] = true
	}

	// 查找下一批节点
	nextNodes := c.findNextNodes(execution, nodeIDs)
	if len(nextNodes) > 0 {
		return c.executeNodes(execution, state, nextNodes)
	}

	return nil
}

// executeTaskNodeWithActor 使用 Actor 执行任务节点
func (c *CoordinatorActor) executeTaskNodeWithActor(execution *WorkflowExecution, state *workflowState, node *NodeDef) error {