diff options
Diffstat (limited to 'services/api/src/trading_api/routers/orders.py')
| -rw-r--r-- | services/api/src/trading_api/routers/orders.py | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/services/api/src/trading_api/routers/orders.py b/services/api/src/trading_api/routers/orders.py index c69dc10..a29ae2f 100644 --- a/services/api/src/trading_api/routers/orders.py +++ b/services/api/src/trading_api/routers/orders.py @@ -5,6 +5,7 @@ import logging from fastapi import APIRouter, HTTPException, Request from shared.sa_models import OrderRow, SignalRow from sqlalchemy import select +from sqlalchemy.exc import OperationalError logger = logging.getLogger(__name__) @@ -35,8 +36,11 @@ async def get_orders(request: Request, limit: int = 50): } for r in rows ] + except OperationalError as exc: + logger.error("Database error fetching orders: %s", exc) + raise HTTPException(status_code=503, detail="Database unavailable") except Exception as exc: - logger.error("Failed to get orders: %s", exc) + logger.error("Failed to get orders: %s", exc, exc_info=True) raise HTTPException(status_code=500, detail="Failed to retrieve orders") @@ -62,6 +66,9 @@ async def get_signals(request: Request, limit: int = 50): } for r in rows ] + except OperationalError as exc: + logger.error("Database error fetching signals: %s", exc) + raise HTTPException(status_code=503, detail="Database unavailable") except Exception as exc: - logger.error("Failed to get signals: %s", exc) + logger.error("Failed to get signals: %s", exc, exc_info=True) raise HTTPException(status_code=500, detail="Failed to retrieve signals") |
