Error Reference

async function fetchWithRetry(url, options, maxRetries = 4) {
  const retryableStatuses = new Set([429, 503]);

  for (let attempt = 0; attempt <= maxRetries; attempt++) {
    const response = await fetch(url, options);

    if (!retryableStatuses.has(response.status)) {
      // Success, or a non-retryable error, return immediately
      return response;
    }

    if (attempt === maxRetries) {
      // We have exhausted our retries
      return response;
    }

    // Exponential backoff: 1s, 2s, 4s, 8s
    const backoffMs = Math.pow(2, attempt) * 1000;
    // Add up to 500ms of random jitter to avoid thundering herd
    const jitterMs = Math.random() * 500;
    const waitMs = backoffMs + jitterMs;

    console.warn(
      `Request failed with ${response.status}. Retrying in ${Math.round(waitMs)}ms ` +
      `(attempt ${attempt + 1} of ${maxRetries})...`
    );

    await new Promise(resolve => setTimeout(resolve, waitMs));
  }
}

// Usage
const response = await fetchWithRetry(
  'https://api-partner.onecluster.co/api/v1/accounts',
  {
    headers: {
      'Authorization': `ApiKey ${process.env.UBN_API_KEY}`,
      'Content-Type': 'application/json',
    },
  }
);

import time
import random
import requests

def fetch_with_retry(url: str, method: str = 'GET', max_retries: int = 4, **kwargs):
    retryable_statuses = {429, 503}

    for attempt in range(max_retries + 1):
        response = requests.request(method, url, **kwargs)

        if response.status_code not in retryable_statuses:
            # Success, or a non-retryable error, return immediately
            return response

        if attempt == max_retries:
            # We have exhausted our retries
            return response

        # Exponential backoff: 1s, 2s, 4s, 8s
        backoff_s = (2 ** attempt)
        # Add up to 0.5s of random jitter
        jitter_s = random.random() * 0.5
        wait_s = backoff_s + jitter_s

        print(
            f"Request failed with {response.status_code}. "
            f"Retrying in {wait_s:.2f}s (attempt {attempt + 1} of {max_retries})..."
        )
        time.sleep(wait_s)


# Usage
response = fetch_with_retry(
    'https://api-partner.onecluster.co/api/v1/accounts',
    headers={
        'Authorization': f"ApiKey {os.environ['UBN_API_KEY']}",
        'Content-Type': 'application/json',
    }
)