Spaces:
Paused
Paused
File size: 1,449 Bytes
a5784e9 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 | from typing import Dict, Optional
from fastapi import HTTPException
def http_error(
status_code: int, detail: str, headers: Optional[Dict[str, str]] = None
) -> HTTPException:
return HTTPException(
status_code=status_code, detail=detail, headers=headers or None
)
def client_cancelled(req_id: str, message: str = "Request cancelled.") -> HTTPException:
return http_error(499, f"[{req_id}] {message}")
def client_disconnected(req_id: str, stage: str = "") -> HTTPException:
suffix = f" during {stage}" if stage else ""
return http_error(499, f"[{req_id}] Client disconnected{suffix}.")
def processing_timeout(
req_id: str, message: str = "Processing timed out."
) -> HTTPException:
return http_error(504, f"[{req_id}] {message}")
def bad_request(req_id: str, message: str) -> HTTPException:
return http_error(400, f"[{req_id}] {message}")
def server_error(req_id: str, message: str) -> HTTPException:
return http_error(500, f"[{req_id}] {message}")
def upstream_error(req_id: str, message: str) -> HTTPException:
# 502 Bad Gateway for upstream/playwright failures
return http_error(502, f"[{req_id}] {message}")
def service_unavailable(req_id: str, retry_after_seconds: int = 30) -> HTTPException:
return http_error(
503,
f"[{req_id}] Service currently unavailable. Please try again later.",
headers={"Retry-After": str(retry_after_seconds)},
)
|