Method Execute

pkg/agent/subagent.go:201–307

Execute 执行子 Agent 任务

(ctx context.Context, req *types.SubAgentRequest)

// Execute 执行子 Agent 任务
func (m *SubAgentManager) Execute(ctx context.Context, req *types.SubAgentRequest) (*types.SubAgentResult, error) {
	// 获取规格
	spec, err := m.GetSpec(req.AgentType)
	if err != nil {
		return nil, err
	}

	// 生成任务 ID
	taskID := uuid.New().String()

	// 设置超时
	timeout := spec.Timeout
	if req.Timeout > 0 {
		timeout = req.Timeout
	}
	if timeout == 0 {
		timeout = m.defaultTimeout
	}

	ctx, cancel := context.WithTimeout(ctx, timeout)
	defer cancel()

	subagentLog.Info(ctx, "starting subagent", map[string]any{
		"task_id":    taskID,
		"agent_type": req.AgentType,
		"timeout":    timeout.String(),
	})

	startTime := time.Now()

	// 创建子 Agent 配置
	agentConfig := m.buildAgentConfig(spec, req, taskID)

	// 创建子 Agent
	agent, err := Create(ctx, agentConfig, m.deps)
	if err != nil {
		return &types.SubAgentResult{
			AgentType: req.AgentType,
			Success:   false,
			Error:     fmt.Sprintf("failed to create subagent: %v", err),
			Duration:  time.Since(startTime),
		}, nil
	}
	defer func() { _ = agent.Close() }() // Best effort cleanup

	// 注册运行中的子 Agent
	handle := &SubAgentHandle{
		ID:            taskID,
		AgentType:     req.AgentType,
		Agent:         agent,
		Request:       req,
		StartTime:     startTime,
		Status:        "running",
		CancelFunc:    cancel,
		ProgressChan:  make(chan *types.SubAgentProgressEvent, 100),
		ParentAgentID: req.ParentAgentID,
	}
	m.registerHandle(handle)