Error handling

if r.status_code == 400:
    body = r.json()
    for issue in body.get("issues", []):
        log.error("validation", path=issue["path"], msg=issue["message"])
    raise ValidationError(body["error"])

import time, random
import requests
from landedfees import LandedFeesClient, ApiError

def with_retry(fn, *args, max_attempts=3, **kwargs):
    for attempt in range(max_attempts):
        try:
            return fn(*args, **kwargs)
        except ApiError as err:
            if err.status in (401, 402, 422) or err.status == 400:
                # Not retryable.
                raise
            if err.status == 429:
                sleep = (err.retry_after or 60) + random.uniform(0.1, 0.5)
            elif err.status >= 500:
                sleep = min(2 ** attempt, 60) + random.uniform(0.1, 0.5)
            else:
                raise
            if attempt == max_attempts - 1:
                raise
            time.sleep(sleep)
    raise RuntimeError("unreachable")

import { randomUUID } from "node:crypto";

const idempotencyKey = randomUUID();
try {
  return await client.calc(payload, { idempotencyKey });
} catch (err) {
  // Safe to retry with the SAME idempotencyKey.
  return await client.calc(payload, { idempotencyKey });
}

resp = client.calc_bulk(payload).json()
if resp["aggregate"]["error_rows"]:
    for e in resp["errors"]:
        log.warning("bulk_row_error", line=e["line_index"], reason=e["reason"])