From 8385bf0ceb80aa5de52eece0b03659ff5c0e0641 Mon Sep 17 00:00:00 2001
From: "manuel.garcia" <manuel.garcia.rodriguez@arcelormittal.com>
Date: Fri, 6 Mar 2020 10:50:20 +0100
Subject: [PATCH] Aggregate function didn't work

---
 gearsclient/redisgears_builder.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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):