diff --git a/redis/client.py b/redis/client.py index 59575cd835..49cc3cf5e7 100755 --- a/redis/client.py +++ b/redis/client.py @@ -1292,6 +1292,12 @@ def client_pause(self, timeout): raise DataError("CLIENT PAUSE timeout must be an integer") return self.execute_command('CLIENT PAUSE', str(timeout)) + def client_unpause(self): + """ + Unpause all redis clients + """ + return self.execute_command('CLIENT UNPAUSE') + def readwrite(self): "Disables read queries for a connection to a Redis Cluster slave node" return self.execute_command('READWRITE') diff --git a/tests/test_commands.py b/tests/test_commands.py index 2da4a89e63..305488a881 100644 --- a/tests/test_commands.py +++ b/tests/test_commands.py @@ -396,6 +396,10 @@ def test_client_pause(self, r): with pytest.raises(exceptions.RedisError): r.client_pause(timeout='not an integer') + @skip_if_server_version_lt('6.2.0') + def test_client_unpause(self, r): + assert r.client_unpause() == b'OK' + def test_config_get(self, r): data = r.config_get() assert 'maxmemory' in data