diff options
author | Mike Bayer <mike_mp@zzzcomputing.com> | 2020-11-02 15:29:38 -0500 |
---|---|---|
committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2020-11-02 15:29:38 -0500 |
commit | f21b5ec4ef54a0923311014e4af50f5804fcf49c (patch) | |
tree | 14008172f22b404e0376104ff5067ff396888616 /lib/sqlalchemy/util/_concurrency_py3k.py | |
parent | ec3f401ac3a1dab5f22f120d14896f77805a2372 (diff) | |
download | sqlalchemy-f21b5ec4ef54a0923311014e4af50f5804fcf49c.tar.gz |
Ensure AsyncAdaptedLock is present
whether or not greenlet is installed
Change-Id: Icd1c5ef3a01ec0d1b8dce0d1def9920700923e51
Diffstat (limited to 'lib/sqlalchemy/util/_concurrency_py3k.py')
-rw-r--r-- | lib/sqlalchemy/util/_concurrency_py3k.py | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/lib/sqlalchemy/util/_concurrency_py3k.py b/lib/sqlalchemy/util/_concurrency_py3k.py index 82125b771..ee3abe5fa 100644 --- a/lib/sqlalchemy/util/_concurrency_py3k.py +++ b/lib/sqlalchemy/util/_concurrency_py3k.py @@ -96,17 +96,6 @@ try: del context.driver return result - class AsyncAdaptedLock: - def __init__(self): - self.mutex = asyncio.Lock() - - def __enter__(self): - await_fallback(self.mutex.acquire()) - return self - - def __exit__(self, *arg, **kw): - self.mutex.release() - except ImportError: # pragma: no cover greenlet = None @@ -119,3 +108,15 @@ except ImportError: # pragma: no cover async def greenlet_spawn(fn, *args, **kw): raise ValueError("Greenlet is required to use this function") + + +class AsyncAdaptedLock: + def __init__(self): + self.mutex = asyncio.Lock() + + def __enter__(self): + await_fallback(self.mutex.acquire()) + return self + + def __exit__(self, *arg, **kw): + self.mutex.release() |