Aggregate function didn't work

manueljgarciar · manueljgarciar · commit 8385bf0ceb80 · 2020-03-06T10:50:20.000+01:00
diff --git 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):
