summaryrefslogtreecommitdiff
path: root/redis/connection.py
diff options
context:
space:
mode:
authorUtkarsh Gupta <utkarshgupta137@gmail.com>2022-05-30 20:05:19 +0530
committerGitHub <noreply@github.com>2022-05-30 17:35:19 +0300
commitc54dfa49dda6a7b3389dc230726293af3ffc68a3 (patch)
treefd972a79a8bef1b29829426c86a7386abb44ba73 /redis/connection.py
parentf704281cf4c1f735c06a13946fcea42fa939e3a5 (diff)
downloadredis-py-c54dfa49dda6a7b3389dc230726293af3ffc68a3.tar.gz
update black to 22.3.0 (#2171)
Diffstat (limited to 'redis/connection.py')
-rwxr-xr-xredis/connection.py19
1 files changed, 5 insertions, 14 deletions
diff --git a/redis/connection.py b/redis/connection.py
index e0dcfc6..1bc2ae1 100755
--- a/redis/connection.py
+++ b/redis/connection.py
@@ -40,9 +40,7 @@ try:
except ImportError:
ssl_available = False
-NONBLOCKING_EXCEPTION_ERROR_NUMBERS = {
- BlockingIOError: errno.EWOULDBLOCK,
-}
+NONBLOCKING_EXCEPTION_ERROR_NUMBERS = {BlockingIOError: errno.EWOULDBLOCK}
if ssl_available:
if hasattr(ssl, "SSLWantReadError"):
@@ -385,10 +383,7 @@ class HiredisParser(BaseParser):
def on_connect(self, connection, **kwargs):
self._sock = connection._sock
self._socket_timeout = connection.socket_timeout
- kwargs = {
- "protocolError": InvalidResponse,
- "replyError": self.parse_error,
- }
+ kwargs = {"protocolError": InvalidResponse, "replyError": self.parse_error}
# hiredis < 0.1.3 doesn't support functions that create exceptions
if not HIREDIS_SUPPORTS_CALLABLE_ERRORS:
@@ -1035,8 +1030,7 @@ class SSLConnection(Connection):
staple_ctx = self.ssl_ocsp_context
staple_ctx.set_ocsp_client_callback(
- ocsp_staple_verifier,
- self.ssl_ocsp_expected_cert,
+ ocsp_staple_verifier, self.ssl_ocsp_expected_cert
)
# need another socket
@@ -1119,10 +1113,7 @@ class UnixDomainSocketConnection(Connection):
self._buffer_cutoff = 6000
def repr_pieces(self):
- pieces = [
- ("path", self.path),
- ("db", self.db),
- ]
+ pieces = [("path", self.path), ("db", self.db)]
if self.client_name:
pieces.append(("client_name", self.client_name))
return pieces
@@ -1288,7 +1279,7 @@ class ConnectionPool:
def __init__(
self, connection_class=Connection, max_connections=None, **connection_kwargs
):
- max_connections = max_connections or 2 ** 31
+ max_connections = max_connections or 2**31
if not isinstance(max_connections, int) or max_connections < 0:
raise ValueError('"max_connections" must be a positive integer')