Black

aio-libs-abandoned · Aug 8, 2021 · 8617538 · 8617538
1 parent bea076b
commit 8617538
Showing 1 changed file with 6 additions and 2 deletions.
diff --git 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