diff --git a/redisai/client.py b/redisai/client.py
index 1dbfd42..1372821 100644
--- a/redisai/client.py
+++ b/redisai/client.py
@@ -669,7 +669,8 @@ def modelrun(self,
         return self
 
     def run(self):
-        results = self.executor(*self.commands)
+        commands = self.commands[:-1]  # removing the last "|>
+        results = self.executor(*commands)
         if self.enable_postprocess:
             out = []
             for res, fn in zip(results, self.result_processors):