diff --git a/letta/server/db.py b/letta/server/db.py index 980e3ecd..e7c40db3 100644 --- a/letta/server/db.py +++ b/letta/server/db.py @@ -3,7 +3,7 @@ import uuid from contextlib import asynccontextmanager from typing import AsyncGenerator -from sqlalchemy import NullPool +from sqlalchemy import NullPool, text from sqlalchemy.ext.asyncio import ( AsyncEngine, AsyncSession, @@ -88,6 +88,10 @@ class DatabaseRegistry: try: async with async_session_factory() as session: try: + result = await session.execute(text("SELECT pg_backend_pid(), current_setting('statement_timeout')")) + pid, timeout = result.one() + logger.warning(f"[stmt_timeout_debug] pid={pid} statement_timeout={timeout}") + await session.rollback() yield session await session.commit() except asyncio.CancelledError: