Merge pull request #580 from eshizhan/master

Add WAIT command for Redis synchronous replication

1 files changed, 9 insertions, 0 deletions

diff --git a/redis/client.py b/redis/client.py
index c99b817..8b5a3fa 100755
--- a/redis/client.py
+++ b/redis/client.py
@@ -767,6 +767,15 @@ class StrictRedis(object):
         """
         return self.execute_command('TIME')
 
+    def wait(self, num_replicas, timeout):
+        """
+        Redis synchronous replication
+        That returns the number of replicas that processed the query when
+        we finally have at least ``num_replicas``, or when the ``timeout`` was
+        reached.
+        """
+        return self.execute_command('WAIT', num_replicas, timeout)
+
     # BASIC KEY COMMANDS
     def append(self, key, value):
         """