diff --git a/gearsclient/redisgears_builder.py b/gearsclient/redisgears_builder.py
index 68c588c..834479e 100644
--- a/gearsclient/redisgears_builder.py
+++ b/gearsclient/redisgears_builder.py
@@ -287,7 +287,7 @@ def limit(self, count, offset=0):
 
     def run(self, arg=None, collect=True, **kargs):
         self.map(lambda x: cloudpickle.dumps(x))
-        self.pipe.run(arg, False, collect)
+        self.pipe.run(arg, False, collect, **kargs)
         selfBytes = cloudpickle.dumps(self.pipe)
         serverCode = '''
 import cloudpickle