From f5d22681895dbb4bf2a84db4543b92e09e538e4c Mon Sep 17 00:00:00 2001 From: Andy McCurdy Date: Mon, 28 Jul 2014 18:01:07 -0700 Subject: fix for pipelines when sending large values --- redis/connection.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/redis/connection.py b/redis/connection.py index eb3fba4..2d666fb 100755 --- a/redis/connection.py +++ b/redis/connection.py @@ -629,9 +629,9 @@ class Connection(object): buffer_length = 0 for cmd in commands: - packed = self.pack_command(*cmd)[0] - pieces.append(packed) - buffer_length += len(packed) + for chunk in self.pack_command(*cmd): + pieces.append(chunk) + buffer_length += len(chunk) if buffer_length > 6000: output.append(SYM_EMPTY.join(pieces)) -- cgit v1.2.1