Skip to content

WIP multi sessions

Pre-release
Pre-release
Compare
Choose a tag to compare
@h0rn3t h0rn3t released this 18 Oct 22:32
· 1 commit to main since this release
5b36546

WIP multi sessions

@router.get("/concurrent-queries")
async def parallel_select():
    async with db(multi_sessions=True):
        async def execute_query(query):
            return await db.session.execute(text(query))

        tasks = [
            asyncio.create_task(execute_query("SELECT 1")),
            asyncio.create_task(execute_query("SELECT 2")),
            asyncio.create_task(execute_query("SELECT 3")),
            asyncio.create_task(execute_query("SELECT 4")),
            asyncio.create_task(execute_query("SELECT 5")),
            asyncio.create_task(execute_query("SELECT 6")),
        ]

        await asyncio.gather(*tasks)