Merge pull request #5 from manueljgarciar/bug_aggregate_function

Meir Shpilraien (Spielrein) · web-flow · commit 22e3a3bf63e7 · 2020-03-08T11:43:29.000+02:00
Aggregate function didn't work
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):
