diff --git a/aioredis/connection.py b/aioredis/connection.py
index 74877bd8b..0f41bac48 100644
--- a/aioredis/connection.py
+++ b/aioredis/connection.py
@@ -215,7 +215,9 @@ def on_connect(self, connection: "Connection"):
     async def can_read(self, timeout: float) -> bool:
         raise NotImplementedError()
 
-    async def read_response(self) -> Union[EncodableT, ResponseError, None, List[EncodableT]]:
+    async def read_response(
+        self,
+    ) -> Union[EncodableT, ResponseError, None, List[EncodableT]]:
         raise NotImplementedError()
 
 
@@ -522,7 +524,9 @@ async def read_response(self) -> Union[EncodableT, List[EncodableT]]:
             self.on_disconnect()
             raise ConnectionError(SERVER_CLOSED_CONNECTION_ERROR) from None
 
-        response: Union[EncodableT, ConnectionError, List[Union[EncodableT, ConnectionError]]]
+        response: Union[
+            EncodableT, ConnectionError, List[Union[EncodableT, ConnectionError]]
+        ]
         # _next_response might be cached from a can_read() call
         if self._next_response is not False:
             response = self._next_response