diff --git a/cluster_test.go b/cluster_test.go index a142f8c..8ca922c 100644 --- a/cluster_test.go +++ b/cluster_test.go @@ -583,6 +583,7 @@ var _ = Describe("ClusterClient", func() { }) _ = client.ForEachSlave(func(slave *redis.Client) error { + defer GinkgoRecover() Eventually(func() int64 { return slave.DBSize().Val() }, 30*time.Second).Should(Equal(int64(0)))