diff --git a/baseplate/clients/redis_cluster.py b/baseplate/clients/redis_cluster.py index 635222b21..04f3f3816 100644 --- a/baseplate/clients/redis_cluster.py +++ b/baseplate/clients/redis_cluster.py @@ -195,6 +195,7 @@ def pipeline(self, name: str) -> "MonitoredClusterRedisPipeline": self.server_span, self.connection_pool, self.response_callbacks, + read_from_replicas=self.read_from_replicas, ) # No transaction support in redis-py-cluster