flaky

redis-rb · May 28, 2024 · fe04811 · fe04811
1 parent ce49bc7
commit fe04811
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/test/test_against_cluster_state.rb b/test/test_against_cluster_state.rb
@@ -165,6 +165,8 @@ def wait_for_replication
       server_side_timeout = (TEST_TIMEOUT_SEC * 1000).to_i
       swap_timeout(@client, timeout: 0.1) do |client|
         client.blocking_call(client_side_timeout, 'WAIT', TEST_REPLICA_SIZE, server_side_timeout)
+      rescue RedisClient::Cluster::ErrorCollection => e
+        raise unless e.errors.values.all? { |err| err.message.start_with?('ERR WAIT cannot be used with replica instances') }
       end
     end