def cleanup in base class

Author: agnesnatasya

redis/asyncio/connection.py

@@ -1057,12 +1057,15 @@ class ConnectionPool:
     ``connection_class``.
     """
 
-    @abstractmethod
     def cleanup(self, **options):
         """
         Additional cleanup operations that the connection pool might
-        need to do after a SCAN ITER family command is executed
+        need to do after a SCAN ITER family command is executed.
+
+        See SentinelManagedConnection for an example cleanup operation that
+        might need to be done.
         """
+        pass
 
     @classmethod
     def from_url(cls: Type[_CP], url: str, **kwargs) -> _CP:

redis/connection.py

@@ -1156,6 +1156,16 @@ def __repr__(self) -> (str, str):
             f"({repr(self.connection_class(**self.connection_kwargs))})>"
         )
 
+    def cleanup(self, **options):
+        """
+        Additional cleanup operations that the connection pool might
+        need to do after a SCAN ITER family command is executed.
+
+        See SentinelManagedConnection for an example cleanup operation that
+        might need to be done.
+        """
+        pass
+
     def reset(self) -> None:
         self._lock = threading.Lock()
         self._created_connections = 0