set the auto_close_connection_pool flag on Redis instance with its own pool.

Author: kristjanvalur

redis/asyncio/sentinel.py

@@ -335,10 +335,13 @@ def master_for(
         kwargs["is_master"] = True
         connection_kwargs = dict(self.connection_kwargs)
         connection_kwargs.update(kwargs)
+
+        connection_pool = connection_pool_class(service_name, self, **connection_kwargs)
+        # The Redis object "owns" the pool
+        auto_close_connection_pool = True
         return redis_class(
-            connection_pool=connection_pool_class(
-                service_name, self, **connection_kwargs
-            )
+            connection_pool=connection_pool,
+            auto_close_connection_pool=auto_close_connection_pool,
         )
 
     def slave_for(
@@ -368,8 +371,11 @@ def slave_for(
         kwargs["is_master"] = False
         connection_kwargs = dict(self.connection_kwargs)
         connection_kwargs.update(kwargs)
+
+        connection_pool = connection_pool_class(service_name, self, **connection_kwargs)
+        # The Redis object "owns" the pool
+        auto_close_connection_pool = True
         return redis_class(
-            connection_pool=connection_pool_class(
-                service_name, self, **connection_kwargs
-            )
+            connection_pool=connection_pool,
+            auto_close_connection_pool=auto_close_connection_pool,
         )