summaryrefslogtreecommitdiff
path: root/tests/test_cluster.py
diff options
context:
space:
mode:
authorDongkeun Lee <3315213+zakaf@users.noreply.github.com>2023-01-11 18:55:45 +0900
committerGitHub <noreply@github.com>2023-01-11 11:55:45 +0200
commit7dd73a306add608807c372a98d833b7cb3394681 (patch)
treed8119dd4bf102bb0bbcb422feebbabb113a29b00 /tests/test_cluster.py
parentbae6385c1b0097a1d85c7825604170477d193481 (diff)
downloadredis-py-7dd73a306add608807c372a98d833b7cb3394681.tar.gz
add support for custom connection pool class in NodesManager (#2547)
Co-authored-by: zach.lee <zach.lee@sendbird.com>
Diffstat (limited to 'tests/test_cluster.py')
-rw-r--r--tests/test_cluster.py17
1 files changed, 16 insertions, 1 deletions
diff --git a/tests/test_cluster.py b/tests/test_cluster.py
index 55b660c..da6a8e4 100644
--- a/tests/test_cluster.py
+++ b/tests/test_cluster.py
@@ -18,7 +18,7 @@ from redis.cluster import (
get_node_name,
)
from redis.commands import CommandsParser
-from redis.connection import Connection
+from redis.connection import BlockingConnectionPool, Connection, ConnectionPool
from redis.crc import key_slot
from redis.exceptions import (
AskError,
@@ -2496,6 +2496,21 @@ class TestNodesManager:
else:
assert startup_nodes == ["my@DNS.com:7000"]
+ @pytest.mark.parametrize(
+ "connection_pool_class", [ConnectionPool, BlockingConnectionPool]
+ )
+ def test_connection_pool_class(self, connection_pool_class):
+ rc = get_mocked_redis_client(
+ url="redis://my@DNS.com:7000",
+ cluster_slots=default_cluster_slots,
+ connection_pool_class=connection_pool_class,
+ )
+
+ for node in rc.nodes_manager.nodes_cache.values():
+ assert isinstance(
+ node.redis_connection.connection_pool, connection_pool_class
+ )
+
@pytest.mark.onlycluster
class TestClusterPubSubObject: