Method executeTaskNode

pkg/workflow/engine.go:623–666

executeTaskNode 执行任务节点

(execution *WorkflowExecution, node *NodeDef, result *NodeResult)

// executeTaskNode 执行任务节点
func (e *Engine) executeTaskNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error {
	if node.Agent == nil {
		return errors.New("task node requires agent configuration")
	}

	// 创建Agent
	agent, err := e.agentFactory.CreateAgent(execution.Context.Context, node.Agent, node.Config)
	if err != nil {
		return fmt.Errorf("failed to create agent: %w", err)
	}

	// 准备输入消息
	inputMessage, err := e.prepareInputMessage(execution, node)
	if err != nil {
		return fmt.Errorf("failed to prepare input: %w", err)
	}

	// 设置超时
	ctx := execution.Context.Context
	if node.Timeout > 0 {
		var cancel context.CancelFunc
		ctx, cancel = context.WithTimeout(ctx, node.Timeout)
		defer cancel()
	}

	// 执行Agent
	reader := agent.Execute(ctx, inputMessage)
	for {
		event, err := reader.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			return fmt.Errorf("agent execution failed: %w", err)
		}

		if event != nil {
			// 处理事件
			result.Outputs = e.processAgentEvent(event, result.Outputs)
		}
	}

	return nil
}

// executeConditionNode 执行条件节点
func (e *Engine) executeConditionNode(execution *WorkflowExecution, node *NodeDef, result *NodeResult) error {