Fix for cluster sends recursive MOVED error in very short time.

redis · Nov 21, 2019 · 1f59ca1 · 1f59ca1
1 parent c7b69ba
commit 1f59ca1
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/lib/redis/cluster.rb b/lib/redis/cluster.rb
@@ -216,7 +216,10 @@ def try_send(node, method_name, *args, retry_count: 3, &block)
       node.public_send(method_name, *args, &block)
     rescue CommandError => err
       if err.message.start_with?('MOVED')
-        assign_redirection_node(err.message).public_send(method_name, *args, &block)
+        raise if retry_count <= 0
+        node = assign_redirection_node(err.message)
+        retry_count -= 1
+        retry
       elsif err.message.start_with?('ASK')
         raise if retry_count <= 0
         node = assign_asking_node(err.message)