test: Disable tests for cancelled context

Author: armsnyder

commands_test.go

@@ -4843,7 +4843,8 @@ var _ = Describe("Commands", func() {
 			Expect(err).To(Equal(redis.Nil))
 		})
 
-		Describe("canceled context", func() {
+		// https://github.com/redis/go-redis/issues/2276
+		PDescribe("canceled context", func() {
 			It("should unblock XRead", func() {
 				ctx2, cancel := context.WithCancel(ctx)
 				errCh := make(chan error, 1)
@@ -5042,7 +5043,8 @@ var _ = Describe("Commands", func() {
 				Expect(n).To(Equal(int64(2)))
 			})
 
-			Describe("canceled context", func() {
+			// https://github.com/redis/go-redis/issues/2276
+			PDescribe("canceled context", func() {
 				It("should unblock XReadGroup", func() {
 					ctx2, cancel := context.WithCancel(ctx)
 					errCh := make(chan error, 1)

internal_test.go

@@ -352,7 +352,8 @@ var _ = Describe("withConn", func() {
 		Expect(client.connPool.Len()).To(Equal(1))
 	})
 
-	It("should remove the connection from the pool if the context is canceled", func() {
+	// https://github.com/redis/go-redis/issues/2276
+	PIt("should remove the connection from the pool if the context is canceled", func() {
 		var conn *pool.Conn
 
 		ctx2, cancel := context.WithCancel(ctx)

pubsub_test.go

@@ -569,7 +569,8 @@ var _ = Describe("PubSub", func() {
 		Expect(msg.Payload).To(Equal(text))
 	})
 
-	Describe("canceled context", func() {
+	// https://github.com/redis/go-redis/issues/2276
+	PDescribe("canceled context", func() {
 		It("should unblock ReceiveMessage", func() {
 			pubsub := client.Subscribe(ctx, "mychannel")
 			defer pubsub.Close()