Function run_out_of_band

examples/asyncio/gather_orm_statements.py:46–63

run an ORM statement in a distinct session, returning the frozen results

(async_sessionmaker, statement, merge_results=True)

async def run_out_of_band(async_sessionmaker, statement, merge_results=True):
    """run an ORM statement in a distinct session,
    returning the frozen results
    """

    async with async_sessionmaker() as oob_session:
        # use AUTOCOMMIT for each connection to reduce transaction
        # overhead / contention
        await oob_session.connection(
            execution_options={"isolation_level": "AUTOCOMMIT"}
        )

        result = await oob_session.execute(statement)

        if merge_results:
            return result.freeze()
        else:
            await result.close()


async def async_main():