Method runTask

pkg/tools/builtin/task.go:220–253

runTask 启动任务

(ctx context.Context, input map[string]any)

// runTask 启动任务
func (t *TaskTool) runTask(ctx context.Context, input map[string]any) (any, error) {
	description := GetStringParam(input, "description", "")
	subagentType := GetStringParam(input, "subagent_type", "")
	prompt := GetStringParam(input, "prompt", "")
	model := GetStringParam(input, "model", "")
	timeoutMinutes := GetIntParam(input, "timeout_minutes", 30)
	async := GetBoolParam(input, "async", true)

	if subagentType == "" {
		return NewClaudeErrorResponse(errors.New("subagent_type is required for run action")), nil
	}
	if prompt == "" {
		return NewClaudeErrorResponse(errors.New("prompt is required for run action")), nil
	}

	// 验证子代理类型
	validSubagents := []string{"general-purpose", "Explore", "Plan"}
	subagentValid := slices.Contains(validSubagents, subagentType)
	if !subagentValid {
		return NewClaudeErrorResponse(
			fmt.Errorf("invalid subagent_type: %s", subagentType),
			"支持的代理类型: general-purpose, Explore, Plan",
		), nil
	}

	start := time.Now()
	taskExecutor := GetGlobalTaskExecutor()

	if taskExecutor.executorFactory != nil {
		return t.executeWithTaskExecutor(ctx, taskExecutor, subagentType, prompt, model, description, timeoutMinutes, 100, async, start)
	}

	return t.executeWithSubagentManager(ctx, subagentType, prompt, model, description, "", timeoutMinutes, 100, async, start)
}

// executeWithTaskExecutor 使用新的 TaskExecutor 执行（真正的子 Agent）
func (t *TaskTool) executeWithTaskExecutor(ctx context.Context, executor *TaskExecutor, subagentType, prompt, model, description string, timeoutMinutes, priority int, async bool, start time.Time) (any, error) {