Add redis/redis-py@88e5bd8

support for client unpause (redis/redis-py#1512)

Signed-off-by: Andrew-Chen-Wang <acwangpython@gmail.com>

aioredis/client.py

@@ -1449,6 +1449,12 @@ def client_pause(self, timeout: int) -> Awaitable:
             raise DataError("CLIENT PAUSE timeout must be an integer")
         return self.execute_command("CLIENT PAUSE", str(timeout))
 
+    def client_unpause(self) -> Awaitable:
+        """
+        Unpause all redis clients
+        """
+        return self.execute_command("CLIENT UNPAUSE")
+
     def readwrite(self) -> Awaitable:
         """Disables read queries for a connection to a Redis Cluster slave node"""
         return self.execute_command("READWRITE")

tests/test_commands.py

@@ -481,6 +481,10 @@ async def test_client_pause(self, r: aioredis.Redis):
         with pytest.raises(exceptions.RedisError):
             await r.client_pause(timeout="not an integer")
 
+    @skip_if_server_version_lt("6.2.0")
+    async def test_client_unpause(self, r: aioredis.Redis):
+        assert await r.client_unpause() == b"OK"
+
     async def test_config_get(self, r: aioredis.Redis):
         data = await r.config_get()
         assert "maxmemory" in data