Function NewSequentialAgent

pkg/agent/workflow/sequential.go:39–65

NewSequentialAgent 创建顺序 Agent

(cfg SequentialConfig)

// NewSequentialAgent 创建顺序 Agent
func NewSequentialAgent(cfg SequentialConfig) (*SequentialAgent, error) {
	if cfg.Name == "" {
		return nil, errors.New("agent name is required")
	}

	if len(cfg.SubAgents) == 0 {
		return nil, errors.New("at least one sub-agent is required")
	}

	// SequentialAgent 是 LoopAgent 迭代 1 次的特例
	loopAgent, err := NewLoopAgent(LoopConfig{
		Name:          cfg.Name,
		SubAgents:     cfg.SubAgents,
		MaxIterations: 1,
		StopCondition: func(event *session.Event) bool {
			// Sequential 不依赖 Escalate，总是执行完所有子 Agent
			return false
		},
	})
	if err != nil {
		return nil, fmt.Errorf("failed to create sequential agent: %w", err)
	}

	return &SequentialAgent{
		LoopAgent: loopAgent,
	}, nil
}

// Execute 顺序执行所有子 Agent（仅一次）
func (a *SequentialAgent) Execute(ctx context.Context, message string) *stream.Reader[*session.Event] {