black

Author: kristjanvalur

tests/test_asyncio/test_pubsub.py

@@ -792,7 +792,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 == {

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