diff --git a/cluster/lib/redis/cluster/client.rb b/cluster/lib/redis/cluster/client.rb
index 2d72e2dcd..461a8d4cc 100644
--- a/cluster/lib/redis/cluster/client.rb
+++ b/cluster/lib/redis/cluster/client.rb
@@ -70,8 +70,8 @@ def pipelined(&block)
         handle_errors { super(&block) }
       end
 
-      def multi(&block)
-        handle_errors { super(&block) }
+      def multi(watch: nil, &block)
+        handle_errors { super(watch: watch, &block) }
       end
 
       private
diff --git a/lib/redis/client.rb b/lib/redis/client.rb
index f0f167c41..e17674d9d 100644
--- a/lib/redis/client.rb
+++ b/lib/redis/client.rb
@@ -111,7 +111,7 @@ def pipelined
       Client.translate_error!(error)
     end
 
-    def multi
+    def multi(watch: nil)
       super
     rescue ::RedisClient::Error => error
       Client.translate_error!(error)