Fix broken ASKING impl in regular client

Grokzen · Oct 22, 2015 · 199ee0b · 199ee0b
1 parent 4a2d4d7
commit 199ee0b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rediscluster/client.py b/rediscluster/client.py
@@ -262,6 +262,7 @@ def execute_command(self, *args, **kwargs):
             try:
                 if asking:
                     r.send_command('ASKING')
+                    self.parse_response(r, "ASKING", **kwargs)
                     asking = False
 
                 r.send_command(*args)
@@ -295,7 +296,6 @@ def execute_command(self, *args, **kwargs):
                 if ttl < self.COMMAND_TTL / 2:
                     time.sleep(0.05)
             except AskError as e:
-                node = self.connection_pool.nodes.set_node(e.host, e.port, server_type='master')
                 redirect_addr, asking = "%s:%s" % (e.host, e.port), True
             finally:
                 self.connection_pool.release(r)