diff options
| author | Federico Caselli <cfederico87@gmail.com> | 2021-01-24 20:48:30 +0100 |
|---|---|---|
| committer | Federico Caselli <cfederico87@gmail.com> | 2021-01-24 20:48:30 +0100 |
| commit | 35cc1fa3f6ff962676f571ae30851f4b4d96762a (patch) | |
| tree | 11cad3a197ee6335a24ed9068d0b4b982fddb312 | |
| parent | dc096c9b23885a254fcde83fe38efde65b339b40 (diff) | |
| download | sqlalchemy-fix_asyncio_run_py36.tar.gz | |
Also fix asyncio exception imports.fix_asyncio_run_py36
The python documentation imports everything directly from the
asyncio package, and it seems that py < 3.8 does not have the
asyncio.exception module
Change-Id: I4719185f02f3c8d030ff24601e15f81767ba7d5a
| -rw-r--r-- | lib/sqlalchemy/util/queue.py | 14 |
1 files changed, 4 insertions, 10 deletions
diff --git a/lib/sqlalchemy/util/queue.py b/lib/sqlalchemy/util/queue.py index 30e388248..0cee2f411 100644 --- a/lib/sqlalchemy/util/queue.py +++ b/lib/sqlalchemy/util/queue.py @@ -237,7 +237,7 @@ class AsyncAdaptedQueue: def put_nowait(self, item): try: return self._queue.put_nowait(item) - except asyncio.queues.QueueFull as err: + except asyncio.QueueFull as err: compat.raise_( Full(), replace_context=err, @@ -254,10 +254,7 @@ class AsyncAdaptedQueue: ) else: return self.await_(self._queue.put(item)) - except ( - asyncio.queues.QueueFull, - asyncio.exceptions.TimeoutError, - ) as err: + except (asyncio.QueueFull, asyncio.TimeoutError) as err: compat.raise_( Full(), replace_context=err, @@ -266,7 +263,7 @@ class AsyncAdaptedQueue: def get_nowait(self): try: return self._queue.get_nowait() - except asyncio.queues.QueueEmpty as err: + except asyncio.QueueEmpty as err: compat.raise_( Empty(), replace_context=err, @@ -283,10 +280,7 @@ class AsyncAdaptedQueue: ) else: return self.await_(self._queue.get()) - except ( - asyncio.queues.QueueEmpty, - asyncio.exceptions.TimeoutError, - ) as err: + except (asyncio.QueueEmpty, asyncio.TimeoutError) as err: compat.raise_( Empty(), replace_context=err, |