fix connection leak

Author: kefu-reddit

rediscluster/client.py

@@ -605,7 +605,6 @@ def _execute_command(self, *args, **kwargs):
                             slot,
                             self.read_from_replicas and (command in self.READ_COMMANDS)
                         )
-                        is_read_replica = node['server_type'] == 'slave'
 
                     connection = self.connection_pool.get_connection_by_node(node)
 

rediscluster/pipeline.py

@@ -214,6 +214,7 @@ def _send_cluster_commands(self, stack, raise_on_error=True, allow_redirections=
                     connection = connection_by_node[node_name]
                 else:
                     connection = self.connection_pool.get_connection_by_node(node)
+                    connection_by_node[node_name] = connection
                 nodes[node_name] = NodeCommands(self.parse_response, connection)
 
             nodes[node_name].append(c)

setup.py

@@ -20,7 +20,7 @@
 
 setup(
     name="redis-py-cluster-patched",
-    version="2.1.0.999.4",
+    version="2.1.0.999.5",
     description="Library for communicating with Redis Clusters. Built on top of redis-py lib",
     long_description=readme + '\n\n' + history,
     long_description_content_type="text/markdown",
@@ -30,7 +30,7 @@
     maintainer_email='Grokzen@gmail.com',
     packages=["rediscluster"],
     url='http://github.com/grokzen/redis-py-cluster',
-    download_url="https://github.com/duke-cliff/redis-py-cluster/archive/2.1.0.999.4.tar.gz",
+    download_url="https://github.com/duke-cliff/redis-py-cluster/archive/2.1.0.999.5.tar.gz",
     license='MIT',
     install_requires=[
         'redis>=3.0.0,<4.0.0'