summaryrefslogtreecommitdiff
path: root/tests/test_cluster.py
diff options
context:
space:
mode:
authorAnurag Bandyopadhyay <angbpy@gmail.com>2023-05-08 13:31:57 +0530
committerGitHub <noreply@github.com>2023-05-08 11:01:57 +0300
commitcfdcfd87acdc10bedba6230b0cbe7dcf44b4652a (patch)
tree441cd541023347c2ac3b2c161fc93c64970b3865 /tests/test_cluster.py
parent906e41349d8751f721c452494cdcdb5455258719 (diff)
downloadredis-py-cfdcfd87acdc10bedba6230b0cbe7dcf44b4652a.tar.gz
Add support for cluster myshardid (#2704)
* feat: adding support for cluster myshardid * lint fix * fix: comment fix and async test * fix: adding version check * fix lint: * linters --------- Co-authored-by: Anuragkillswitch <70265851+Anuragkillswitch@users.noreply.github.com> Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com> Co-authored-by: dvora-h <dvora.heller@redis.com>
Diffstat (limited to 'tests/test_cluster.py')
-rw-r--r--tests/test_cluster.py7
1 files changed, 7 insertions, 0 deletions
diff --git a/tests/test_cluster.py b/tests/test_cluster.py
index 8371cc5..705e753 100644
--- a/tests/test_cluster.py
+++ b/tests/test_cluster.py
@@ -1162,6 +1162,13 @@ class TestClusterRedisCommands:
for attribute in node.keys():
assert attribute in attributes
+ @skip_if_server_version_lt("7.2.0")
+ @skip_if_redis_enterprise()
+ def test_cluster_myshardid(self, r):
+ myshardid = r.cluster_myshardid()
+ assert isinstance(myshardid, str)
+ assert len(myshardid) > 0
+
@skip_if_redis_enterprise()
def test_cluster_addslots(self, r):
node = r.get_random_node()