Method Execute

pkg/tools/builtin/task_executor.go:61–127

Execute 执行任务（同步）

(ctx context.Context, agentType, prompt string, opts *TaskExecuteOptions)

// Execute 执行任务（同步）
func (te *TaskExecutor) Execute(ctx context.Context, agentType, prompt string, opts *TaskExecuteOptions) (*TaskExecution, error) {
	te.mu.RLock()
	factory := te.executorFactory
	te.mu.RUnlock()

	if factory == nil {
		return nil, errors.New("executor factory not configured, subagent execution not available")
	}

	// 创建执行器
	executor, err := factory.Create(agentType)
	if err != nil {
		return nil, fmt.Errorf("failed to create executor for %s: %w", agentType, err)
	}

	// 构建请求
	req := &types.SubAgentRequest{
		AgentType: agentType,
		Task:      prompt,
		Context:   opts.Context,
	}

	if opts.Timeout > 0 {
		req.Timeout = opts.Timeout
	}

	// 执行
	startTime := time.Now()
	result, err := executor.Execute(ctx, req)

	execution := &TaskExecution{
		TaskID:    fmt.Sprintf("task_%d", startTime.UnixNano()),
		Subagent:  agentType,
		Model:     opts.Model,
		Status:    "completed",
		StartTime: startTime,
		Duration:  time.Since(startTime),
	}

	if err != nil {
		execution.Status = "failed"
		execution.Error = err.Error()
		return execution, nil
	}

	if result != nil {
		execution.Result = result.Output
		if result.Success {
			execution.Status = "completed"
		} else {
			execution.Status = "failed"
			execution.Error = result.Error
		}
		execution.Metadata = map[string]any{
			"tokens_used": result.TokensUsed,
			"step_count":  result.StepCount,
			"artifacts":   result.Artifacts,
		}