diff options
Diffstat (limited to 'lib/sqlalchemy/util/queue.py')
| -rw-r--r-- | lib/sqlalchemy/util/queue.py | 21 |
1 files changed, 4 insertions, 17 deletions
diff --git a/lib/sqlalchemy/util/queue.py b/lib/sqlalchemy/util/queue.py index 12b372202..4769d5886 100644 --- a/lib/sqlalchemy/util/queue.py +++ b/lib/sqlalchemy/util/queue.py @@ -21,7 +21,6 @@ condition. from collections import deque from time import time as _time -from . import compat from .compat import threading from .concurrency import asyncio from .concurrency import await_fallback @@ -238,10 +237,7 @@ class AsyncAdaptedQueue: try: return self._queue.put_nowait(item) except asyncio.QueueFull as err: - compat.raise_( - Full(), - replace_context=err, - ) + raise Full() from err def put(self, item, block=True, timeout=None): if not block: @@ -255,19 +251,13 @@ class AsyncAdaptedQueue: else: return self.await_(self._queue.put(item)) except (asyncio.QueueFull, asyncio.TimeoutError) as err: - compat.raise_( - Full(), - replace_context=err, - ) + raise Full() from err def get_nowait(self): try: return self._queue.get_nowait() except asyncio.QueueEmpty as err: - compat.raise_( - Empty(), - replace_context=err, - ) + raise Empty() from err def get(self, block=True, timeout=None): if not block: @@ -281,10 +271,7 @@ class AsyncAdaptedQueue: else: return self.await_(self._queue.get()) except (asyncio.QueueEmpty, asyncio.TimeoutError) as err: - compat.raise_( - Empty(), - replace_context=err, - ) + raise Empty() from err class FallbackAsyncAdaptedQueue(AsyncAdaptedQueue): |