Adds `sync` flag to flushdb and flushall

Uses sync as async is a keyword. Defaults to Redis pre v4 behavior.

Signed-off-by: Itamar Haber <itamar@redislabs.com>

1 files changed, 22 insertions, 6 deletions

diff --git a/redis/client.py b/redis/client.py
index aaa7433..9b0086b 100755
--- a/redis/client.py
+++ b/redis/client.py
@@ -841,13 +841,29 @@ class StrictRedis(object):
         "Echo the string back from the server"
         return self.execute_command('ECHO', value)
 
-    def flushall(self):
-        "Delete all keys in all databases on the current host"
-        return self.execute_command('FLUSHALL')
+    def flushall(self, sync=True):
+        """
+        Delete all keys in all databases on the current host.
+
+        ``sync`` indicates whether the operation is executed
+        synchronously by the server.
+        """
+        args = []
+        if not sync:
+            args.append(Token.get_token('ASYNC'))
+        return self.execute_command('FLUSHALL', *args)
 
-    def flushdb(self):
-        "Delete all keys in the current database"
-        return self.execute_command('FLUSHDB')
+    def flushdb(self, sync=True):
+        """
+        Delete all keys in the current database.
+
+        ``sync`` indicates whether the operation is executed
+        synchronously by the server.
+        """
+        args = []
+        if not sync:
+            args.append(Token.get_token('ASYNC'))
+        return self.execute_command('FLUSHDB', *args)
 
     def swapdb(self, first, second):
         "Swap two databases"