async def get_asyncpg_session() -> AsyncIterator[AsyncSession]:
    async with AsyncSession(
        async_engine,
        expire_on_commit=False,
    ) as session:
        async with session.begin():
            yield session