Skip to content

Commit 6207641

Browse files
authored
Add support for ModuleCommands in cluster (#2951)
1 parent 2df75ad commit 6207641

File tree

4 files changed

+8
-2
lines changed

4 files changed

+8
-2
lines changed

redis/cluster.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -295,6 +295,10 @@ class AbstractRedisCluster:
295295
"LATENCY HISTORY",
296296
"LATENCY LATEST",
297297
"LATENCY RESET",
298+
"MODULE LIST",
299+
"MODULE LOAD",
300+
"MODULE UNLOAD",
301+
"MODULE LOADEX",
298302
],
299303
DEFAULT_NODE,
300304
),

redis/commands/cluster.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,11 +32,13 @@
3232
AsyncFunctionCommands,
3333
AsyncGearsCommands,
3434
AsyncManagementCommands,
35+
AsyncModuleCommands,
3536
AsyncScriptCommands,
3637
DataAccessCommands,
3738
FunctionCommands,
3839
GearsCommands,
3940
ManagementCommands,
41+
ModuleCommands,
4042
PubSubCommands,
4143
ResponseT,
4244
ScriptCommands,
@@ -873,6 +875,7 @@ class RedisClusterCommands(
873875
ScriptCommands,
874876
FunctionCommands,
875877
GearsCommands,
878+
ModuleCommands,
876879
RedisModuleCommands,
877880
):
878881
"""
@@ -903,6 +906,7 @@ class AsyncRedisClusterCommands(
903906
AsyncScriptCommands,
904907
AsyncFunctionCommands,
905908
AsyncGearsCommands,
909+
AsyncModuleCommands,
906910
):
907911
"""
908912
A class for all Redis Cluster commands

tests/test_asyncio/test_commands.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3213,7 +3213,6 @@ async def test_memory_usage(self, r: redis.Redis):
32133213
assert isinstance(await r.memory_usage("foo"), int)
32143214

32153215
@skip_if_server_version_lt("4.0.0")
3216-
@pytest.mark.onlynoncluster
32173216
async def test_module_list(self, r: redis.Redis):
32183217
assert isinstance(await r.module_list(), list)
32193218
for x in await r.module_list():

tests/test_commands.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4909,7 +4909,6 @@ def test_latency_latest(self, r: redis.Redis):
49094909
def test_latency_reset(self, r: redis.Redis):
49104910
assert r.latency_reset() == 0
49114911

4912-
@pytest.mark.onlynoncluster
49134912
@skip_if_server_version_lt("4.0.0")
49144913
@skip_if_redis_enterprise()
49154914
def test_module_list(self, r):

0 commit comments

Comments
 (0)