summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/util/queue.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2020-09-28 14:08:59 -0400
committerMike Bayer <mike_mp@zzzcomputing.com>2020-09-28 15:17:26 -0400
commitc3f102c9fe9811fd5286628cc6aafa5fbc324621 (patch)
tree4a78723089ded623701667de1eee21d22edbe6c1 /lib/sqlalchemy/util/queue.py
parent75ac0abc7d5653d10006769a881374a46b706db5 (diff)
downloadsqlalchemy-c3f102c9fe9811fd5286628cc6aafa5fbc324621.tar.gz
upgrade to black 20.8b1
It's better, the majority of these changes look more readable to me. also found some docstrings that had formatting / quoting issues. Change-Id: I582a45fde3a5648b2f36bab96bad56881321899b
Diffstat (limited to 'lib/sqlalchemy/util/queue.py')
-rw-r--r--lib/sqlalchemy/util/queue.py12
1 files changed, 8 insertions, 4 deletions
diff --git a/lib/sqlalchemy/util/queue.py b/lib/sqlalchemy/util/queue.py
index 9447abede..3687dc8dc 100644
--- a/lib/sqlalchemy/util/queue.py
+++ b/lib/sqlalchemy/util/queue.py
@@ -220,7 +220,8 @@ class AsyncAdaptedQueue:
return self._queue.put_nowait(item)
except asyncio.queues.QueueFull as err:
compat.raise_(
- Full(), replace_context=err,
+ Full(),
+ replace_context=err,
)
def put(self, item, block=True, timeout=None):
@@ -236,7 +237,8 @@ class AsyncAdaptedQueue:
return self.await_(self._queue.put(item))
except asyncio.queues.QueueFull as err:
compat.raise_(
- Full(), replace_context=err,
+ Full(),
+ replace_context=err,
)
def get_nowait(self):
@@ -244,7 +246,8 @@ class AsyncAdaptedQueue:
return self._queue.get_nowait()
except asyncio.queues.QueueEmpty as err:
compat.raise_(
- Empty(), replace_context=err,
+ Empty(),
+ replace_context=err,
)
def get(self, block=True, timeout=None):
@@ -259,5 +262,6 @@ class AsyncAdaptedQueue:
return self.await_(self._queue.get())
except asyncio.queues.QueueEmpty as err:
compat.raise_(
- Empty(), replace_context=err,
+ Empty(),
+ replace_context=err,
)