From 2bbcb26861ed3957c4728cec4aaf2842191884a9 Mon Sep 17 00:00:00 2001
From: Mohsin Zaidi <2236875+smrz2001@users.noreply.github.com>
Date: Mon, 23 Jan 2023 18:04:32 -0500
Subject: [PATCH] chore: bump pubsub consumer rx timeout

---
 test/integration/pubsub_msg_seen_cache_test.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/test/integration/pubsub_msg_seen_cache_test.go b/test/integration/pubsub_msg_seen_cache_test.go
index 7495080893dd..aca98c91b42d 100644
--- 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 {