diff --git a/redis/asyncio/client.py b/redis/asyncio/client.py index f753a3127d..9c7ce09324 100644 --- a/redis/asyncio/client.py +++ b/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) diff --git a/redis/asyncio/cluster.py b/redis/asyncio/cluster.py index c0a53ca059..07bf45ecb0 100644 --- a/redis/asyncio/cluster.py +++ b/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: