sqlalchemy_async_session_factory.utils¶

Utility functions for connection pool management.

Extracted from GridFlow backend/src/database.py

Functions¶

`suppress_pool_warnings`(→ None)	Suppress connection pool warnings during cleanup.
`setup_pool_event_handlers`(→ None)	Setup event handlers for connection pool.

Module Contents¶

sqlalchemy_async_session_factory.utils.suppress_pool_warnings() → None¶

Suppress connection pool warnings during cleanup.

Suppresses event loop closure warnings that occur during normal connection termination. This is safe because connections are being cleaned up properly, just after the event loop closes.

Call this once during application startup.

Example:

>>> suppress_pool_warnings()

sqlalchemy_async_session_factory.utils.setup_pool_event_handlers(engine: sqlalchemy.ext.asyncio.AsyncEngine) → None¶

Setup event handlers for connection pool.

Adds event listener to suppress errors during connection closure. This handles cleanup gracefully even if event loop is closed.

Args:

engine: AsyncEngine instance

Example:

>>> from sqlalchemy.ext.asyncio import create_async_engine
>>> engine = create_async_engine("postgresql+asyncpg://...")
>>> setup_pool_event_handlers(engine)