Method classifyAttemptError

pkg/runtime/fallback.go:188–210

classifyAttemptError handles an error from a stream attempt: checks for context cancellation, classifies the error, and returns either a per-iteration decision (retry the same model or skip to the next) or a non-nil retErr that the caller must return immediately. This consolidates the identical err

(
	ctx context.Context,
	err error,
	a *agent.Agent,
	modelEntry modelWithFallback,
	attempt int,
	hasFallbacks bool,
	primaryFailedWithNonRetryable *bool,
)

// This consolidates the identical error-handling block that used to
// follow both CreateChatCompletionStream and handleStream calls.
func (e *fallbackExecutor) classifyAttemptError(
	ctx context.Context,
	err error,
	a *agent.Agent,
	modelEntry modelWithFallback,
	attempt int,
	hasFallbacks bool,
	primaryFailedWithNonRetryable *bool,
) (decision retryDecision, retErr error) {
	// Context cancellation is never retryable; bubble up the original
	// error to preserve any cause/wrapping. The returned decision is
	// irrelevant when retErr != nil — by contract the caller returns
	// immediately — but use retryDecisionContinue rather than a magic
	// zero so the value is at least typed and consistent.
	if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {
		return retryDecisionContinue, err
	}
	decision = e.handleModelError(ctx, err, a, modelEntry, attempt, hasFallbacks, primaryFailedWithNonRetryable)
	if decision == retryDecisionReturn {
		return retryDecisionContinue, ctx.Err()
	}
	return decision, nil
}

// execute attempts to create a stream and get a response using the primary model,
// falling back to configured fallback models if the primary fails.