diff --git a/gearsclient/redisgears_builder.py b/gearsclient/redisgears_builder.py
index 2224888..4c99561 100644
--- a/gearsclient/redisgears_builder.py
+++ b/gearsclient/redisgears_builder.py
@@ -220,7 +220,7 @@ def distinct(self):
         return self
 
     def aggregate(self, zero, seqOp, combOp):
-        self.pipe.countby(callback)
+        self.pipe.aggregate(zero, seqOp, combOp)
         return self
 
     def aggregateby(self, extractor, zero, seqOp, combOp):