Spaces:
Sleeping
Sleeping
| import redis.exceptions | |
| from fastapi import Request | |
| from fastapi.responses import JSONResponse | |
| async def redis_connection_error_handler( | |
| request: Request, | |
| exc: redis.exceptions.ConnectionError, | |
| ): | |
| return JSONResponse( | |
| status_code=503, | |
| content={ | |
| "error": "service_unavailable", | |
| "message": ( | |
| "Storage backend is unreachable. " | |
| "If this persists, the service may have exhausted " | |
| "its monthly network quota — check the Redis Cloud dashboard." | |
| ), | |
| "action": "retry_later", | |
| }, | |
| headers={"Retry-After": "3600"}, | |
| ) | |
| async def redis_timeout_error_handler( | |
| request: Request, | |
| exc: redis.exceptions.TimeoutError, | |
| ): | |
| return JSONResponse( | |
| status_code=504, | |
| content={ | |
| "error": "gateway_timeout", | |
| "message": "Storage backend did not respond in time.", | |
| "action": "retry_later", | |
| }, | |
| headers={"Retry-After": "30"}, | |
| ) | |
| async def redis_error_handler( | |
| request: Request, | |
| exc: redis.exceptions.RedisError, | |
| ): | |
| return JSONResponse( | |
| status_code=503, | |
| content={ | |
| "error": "storage_error", | |
| "message": "A storage error occurred. Please try again later.", | |
| "action": "retry_later", | |
| }, | |
| headers={"Retry-After": "60"}, | |
| ) | |