Reformat __del__()

Author: kristjanvalur

redis/asyncio/client.py

@@ -492,7 +492,9 @@ async def __aexit__(self, exc_type, exc_value, traceback):
     # passing _warnings and _grl as argument default since they may be gone
     # by the time __del__ is called at shutdown
     def __del__(
-        self, _warn: Any = warnings.warn, _grl: Any = asyncio.get_running_loop
+        self,
+        _warn: Any = warnings.warn,
+        _grl: Any = asyncio.get_running_loop,
     ) -> None:
         if hasattr(self, "connection") and (self.connection is not None):
             _warn(f"Unclosed client session {self!r}", ResourceWarning, source=self)

redis/asyncio/cluster.py

@@ -423,7 +423,9 @@ def __await__(self) -> Generator[Any, None, "RedisCluster"]:
     _DEL_MESSAGE = "Unclosed RedisCluster client"
 
     def __del__(
-        self, _warn: Any = warnings.warn, _grl: Any = asyncio.get_running_loop
+        self,
+        _warn: Any = warnings.warn,
+        _grl: Any = asyncio.get_running_loop,
     ) -> None:
         if hasattr(self, "_initialize") and not self._initialize:
             _warn(f"{self._DEL_MESSAGE} {self!r}", ResourceWarning, source=self)
@@ -961,7 +963,9 @@ def __eq__(self, obj: Any) -> bool:
     _DEL_MESSAGE = "Unclosed ClusterNode object"
 
     def __del__(
-        self, _warn: Any = warnings.warn, _grl: Any = asyncio.get_running_loop
+        self,
+        _warn: Any = warnings.warn,
+        _grl: Any = asyncio.get_running_loop,
     ) -> None:
         for connection in self._connections:
             if connection.is_connected: