chore: bump pubsub consumer rx timeout

ipfs · Jan 23, 2023 · 5e33745 · 5e33745
1 parent 5c03f35
commit 5e33745
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/test/integration/pubsub_msg_seen_cache_test.go b/test/integration/pubsub_msg_seen_cache_test.go
@@ -193,7 +193,7 @@ func RunMessageSeenCacheTTLTest(t *testing.T, seenMessagesCacheTTL string) error
 	}
 	consumeMessage := func(msgTxt string, shouldFind bool) {
 		// Set up a separate timed context for receiving messages
-		rxCtx, rxCancel := context.WithTimeout(context.Background(), time.Second)
+		rxCtx, rxCancel := context.WithTimeout(context.Background(), 5*time.Second)
 		defer rxCancel()
 		msg, err := consumerSubscription.Next(rxCtx)
 		if shouldFind {