chore: bump pubsub consumer rx timeout

ipfs · Jan 23, 2023 · 2bbcb26 · 2bbcb26
1 parent c8f5d2a
commit 2bbcb26
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 {