@contextlib.contextmanager
    def _transaction(self):
        with self._memory_lock(write=True):
            yield
This just wraps a global write-lock.
dataset/ETHPy150Open openstack/taskflow/taskflow/persistence/backends/impl_memory.py/Connection._transaction