Skip to content

Commit 0ff275f

Browse files
committed
Add some WAIT for tests using replication
1 parent 5e254bb commit 0ff275f

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

test/cluster_client_replicas_test.rb

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,11 @@ def test_client_can_command_with_replica
1313
assert_equal 'OK', r.set("key#{i}", i)
1414
end
1515

16+
begin
17+
r.wait(6, 5_000)
18+
rescue Redis::TimeoutError
19+
end
20+
1621
100.times do |i|
1722
assert_equal i.to_s, r.get("key#{i}")
1823
end
@@ -30,6 +35,11 @@ def test_some_reference_commands_are_sent_to_slaves_if_needed
3035

3136
5.times { |i| r.set("key#{i}", i) }
3237

38+
begin
39+
r.wait(6, 5_000)
40+
rescue Redis::TimeoutError
41+
end
42+
3343
assert_equal %w[key0 key1 key2 key3 key4], r.keys
3444
assert_equal 5, r.dbsize
3545
end

0 commit comments

Comments
 (0)