Function doFetchRequest

packages/trigger-sdk/src/v3/retry.ts:364–410

(
  input: RequestInfo | URL | string,
  init?: RequestInit,
  attemptCount: number = 0
)

}

const doFetchRequest = async (
  input: RequestInfo | URL | string,
  init?: RequestInit,
  attemptCount: number = 0
): Promise<[Response, Span]> => {
  const httpMethod = normalizeHttpMethod(input, init);

  const span = tracer.startSpan(`HTTP ${httpMethod}`, {
    attributes: {
      [SemanticInternalAttributes.STYLE_ICON]: "world",
      ...(attemptCount > 1 ? { ["http.request.resend_count"]: attemptCount - 1 } : {}),
      ...createFetchAttributes(input, init),
    },
  });

  try {
    const response = await fetchWithInterceptors(input, {
      ...init,
      headers: {
        ...init?.headers,
        "x-retry-count": attemptCount.toString(),
      },
    });

    span.setAttributes(createFetchResponseAttributes(response));

    if (!response.ok) {
      span.recordException(`${response.status}: ${response.statusText}`);
      span.setStatus({
        code: SpanStatusCode.ERROR,
        message: `${response.status}: ${response.statusText}`,
      });
    }

    return [response, span];
  } catch (e) {
    if (typeof e === "string" || e instanceof Error) {
      span.recordException(e);
    }

    span.setStatus({ code: SpanStatusCode.ERROR });
    span.setAttribute(SEMATTRS_HTTP_STATUS_CODE, 0);
    span.setAttribute("http.status_text", "This operation was aborted.");

    throw new FetchErrorWithSpan(e, span);
  }
};

const calculateRetryDelayForResponse = async (
  retry: FetchRetryByStatusOptions | undefined,