diff --git a/ring_test.go b/ring_test.go index 4ff0898..e44a404 100644 --- a/ring_test.go +++ b/ring_test.go @@ -379,6 +379,8 @@ var _ = Describe("Ring watch", func() { }) ring.ForEachShard(func(cl *redis.Client) error { + defer GinkgoRecover() + pool := cl.Pool() Expect(pool.Len()).To(BeNumerically("<=", 10)) Expect(pool.IdleLen()).To(BeNumerically("<=", 10))