Method executeStep

pkg/executionplan/executor.go:282–367

executeStep 执行单个步骤

(ctx context.Context, plan *ExecutionPlan, step *Step, toolCtx *tools.ToolContext)

// executeStep 执行单个步骤
func (e *Executor) executeStep(ctx context.Context, plan *ExecutionPlan, step *Step, toolCtx *tools.ToolContext) error {
	// 获取工具
	tool, ok := e.tools[step.ToolName]
	if !ok {
		step.Status = StepStatusFailed
		step.Error = "tool not found: " + step.ToolName
		return fmt.Errorf("tool not found: %s", step.ToolName)
	}

	// 标记步骤开始
	plan.MarkStepStarted(step.Index)

	// 触发步骤开始回调
	if e.onStepStart != nil {
		e.onStepStart(plan, step)
	}

	// 准备输入参数
	var inputParams map[string]any
	if len(step.Parameters) > 0 {
		inputParams = step.Parameters
	} else if step.Input != "" {
		// 尝试从 Input 字符串解析 JSON
		inputParams = make(map[string]any)
		if err := json.Unmarshal([]byte(step.Input), &inputParams); err != nil {
			// 如果解析失败，将整个输入作为 "input" 参数
			inputParams["input"] = step.Input
		}
	} else {
		inputParams = make(map[string]any)
	}

	// 执行工具（带超时）
	execCtx := ctx
	if plan.Options != nil && plan.Options.StepTimeoutMs > 0 {
		var cancel context.CancelFunc
		execCtx, cancel = context.WithTimeout(ctx, time.Duration(plan.Options.StepTimeoutMs)*time.Millisecond)
		defer cancel()
	}

	// 重试逻辑
	var result any
	var execErr error
	maxRetries := max(step.MaxRetries,
		// 默认不重试
		0)

retryLoop:
	for attempt := 0; attempt <= maxRetries; attempt++ {
		if attempt > 0 {
			step.RetryCount = attempt
			// 重试延迟
			if step.RetryDelayMs > 0 {
				select {
				case <-execCtx.Done():
					execErr = execCtx.Err()
					break retryLoop
				case <-time.After(time.Duration(step.RetryDelayMs) * time.Millisecond):