Fix for #161. Make sure we release the connection back to the pool after

execute is called in a pipeline.

1 files changed, 8 insertions, 2 deletions

diff --git a/redis/client.py b/redis/client.py
index 039024d..10e5060 100644
--- a/redis/client.py
+++ b/redis/client.py
@@ -1334,8 +1334,14 @@ class Pipeline(Redis):
             execute = self._execute_transaction
         else:
             execute = self._execute_pipeline
-        conn = self.connection or \
-                   self.connection_pool.get_connection('MULTI', self.shard_hint)
+
+        conn = self.connection
+        if not conn:
+            conn = self.connection_pool.get_connection('MULTI', self.shard_hint)
+            # assign to self.connection so reset() releases the connection
+            # back to the pool after we're done
+            self.connection = conn
+
         try:
             return execute(conn, stack)
         except ConnectionError: