lint & format

Author: kristjanvalur

tests/test_asyncio/test_pubsub.py

@@ -807,7 +807,7 @@ async def mysetup(self, r, method):
         else:
             self.get_message = self.loop_step_listen
 
-        self. task = create_task(self.loop())
+        self.task = create_task(self.loop())
         # get the initial connect message
         message = await self.messages.get()
         assert message == {
@@ -863,7 +863,7 @@ async def test_reconnect_disconnect(self, r: redis.Redis, method):
             async with self.cond:
                 self.state = 1
                 await self.pubsub.connection.disconnect()
-                assert not self.pubsub.connection.is_connected  # it is in a disconnecte state
+                assert not self.pubsub.connection.is_connected
                 # wait for reconnect
                 await self.cond.wait_for(lambda: self.pubsub.connection.is_connected)
                 assert self.state == 3

tests/test_pubsub.py

@@ -639,8 +639,7 @@ def mysetup(self, r, method):
         }
 
     def wait_for_reconnect(self):
-        self.cond.wait_for(
-            lambda: self.pubsub.connection._sock is not None, timeout=2)
+        self.cond.wait_for(lambda: self.pubsub.connection._sock is not None, timeout=2)
         assert self.pubsub.connection._sock is not None  # we didn't time out
         assert self.state == 3
 
@@ -691,7 +690,7 @@ def test_reconnect_disconnect(self, r: redis.Redis, method):
             with self.cond:
                 self.state = 1
                 self.pubsub.connection.disconnect()
-                assert self.pubsub.connection._sock is None  # it is in a disconnected state
+                assert self.pubsub.connection._sock is None
                 # wait for reconnect
                 self.wait_for_reconnect()
         finally: