

def _produce_block(self, mode, connection, savepoint, allow_async=False):
    if (mode is _WRITER):
        self._writer()
    elif (mode is _ASYNC_READER):
        self._async_reader()
    else:
        self._reader(allow_async)
    if connection:
        return self._connection(savepoint)
    else:
        return self._session(savepoint)

dataset/ETHPy150Open openstack/oslo.db/oslo_db/sqlalchemy/enginefacade.py _TransactionContext._produce_block/original