diff --git a/cluster/cluster_test.go b/cluster/cluster_test.go index 993d612e..9b8c2a17 100644 --- a/cluster/cluster_test.go +++ b/cluster/cluster_test.go @@ -92,6 +92,7 @@ func testJoinLeave(t *testing.T) { ) require.NoError(t, err) go p2.Settle(context.Background(), 0*time.Second) + p2.WaitReady() require.Equal(t, 2, p.ClusterSize()) p2.Leave(0 * time.Second)