Fix partial closure error when instantiating redis pool for a global_…

…keyprefix sentinel connection
celery · Jan 4, 2024 · eab8f00 · eab8f00
1 parent 0dec03d
commit eab8f00
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py
@@ -1429,7 +1429,7 @@ def _sentinel_managed_pool(self, asynchronous=False):
 
         return sentinel_inst.master_for(
             master_name,
-            self.Client,
+            redis.StrictRedis,
         ).connection_pool
 
     def _get_pool(self, asynchronous=False):