[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

aioredis/connection.py

@@ -1307,7 +1307,7 @@ def __init__(
         max_connections: Optional[int] = 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')
 

tests/conftest.py

@@ -292,7 +292,7 @@ async def wait_for_command(client: aioredis.Redis, monitor: Monitor, command: st
     if StrictVersion(redis_version) >= StrictVersion("5.0.0"):
         id_str = str(await client.client_id())
     else:
-        id_str = "%08x" % random.randrange(2 ** 32)
+        id_str = "%08x" % random.randrange(2**32)
     key = "__REDIS-PY-%s__" % id_str
     await client.get(key)
     while True:

tests/test_commands.py

@@ -2393,7 +2393,7 @@ async def test_xack(self, r: aioredis.Redis):
     async def test_xadd(self, r: aioredis.Redis):
         stream = "stream"
         message_id = await r.xadd(stream, {"foo": "bar"})
-        assert re.match(br"[0-9]+\-[0-9]+", message_id)
+        assert re.match(rb"[0-9]+\-[0-9]+", message_id)
 
         # explicit message id
         message_id = b"9999999999999999999-0"
@@ -2432,17 +2432,14 @@ async def test_xclaim(self, r: aioredis.Redis):
 
         # reclaim the message as consumer1, but use the justid argument
         # which only returns message ids
-        assert (
-            await r.xclaim(
-                stream,
-                group,
-                consumer1,
-                min_idle_time=0,
-                message_ids=(message_id,),
-                justid=True,
-            )
-            == [message_id]
-        )
+        assert await r.xclaim(
+            stream,
+            group,
+            consumer1,
+            min_idle_time=0,
+            message_ids=(message_id,),
+            justid=True,
+        ) == [message_id]
 
     @skip_if_server_version_lt("5.0.0")
     async def test_xclaim_trimmed(self, r: aioredis.Redis):