engine

database.engine.engine = create_async_engine(settings.DATABASE_URL, echo=settings.DEV, future=True, pool_size=20, max_overflow=20, pool_recycle=3600) module-attribute

database.engine.get_session() async

Create and yield database async session.

Source code in database/engine.py

async def get_session() -> (
	AsyncGenerator[AsyncSession, None]
):  # pragma: no cover
	"""Create and yield database async session."""
	async with AsyncSession(engine) as session:
		yield session