From 97e6c696c39bf4cf49fa5ef51145cfcb2a1a5d71 Mon Sep 17 00:00:00 2001
From: Alex Hong <9397363+hongalex@users.noreply.github.com>
Date: Mon, 8 Mar 2021 15:27:39 -0800
Subject: [PATCH] fix(pubsub): update quiescenceDur in failing e2e test (#3780)

---
 pubsub/internal/longtest/endtoend_test.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pubsub/internal/longtest/endtoend_test.go b/pubsub/internal/longtest/endtoend_test.go
index 6a6218b4fa9..b0a8d7e3531 100644
--- a/pubsub/internal/longtest/endtoend_test.go
+++ b/pubsub/internal/longtest/endtoend_test.go
@@ -184,7 +184,7 @@ func TestEndToEnd_LongProcessingTime(t *testing.T) {
 	sub.ReceiveSettings.Synchronous = true
 	sub.ReceiveSettings.MaxOutstandingMessages = 500
 
-	err = publish(ctx, topic, 1000)
+	err = publish(ctx, topic, 500)
 	topic.Stop()
 	if err != nil {
 		t.Fatalf("publish: %v", err)
@@ -208,7 +208,7 @@ func TestEndToEnd_LongProcessingTime(t *testing.T) {
 	//    deadline extended.
 	// 2. To wait for redelivery of messages that were en route when a Receive
 	//    is canceled. This can take considerably longer than the ack deadline.
-	quiescenceDur := ackDeadline * 6
+	quiescenceDur := 12 * ackDeadline
 	quiescenceTimer := time.NewTimer(quiescenceDur)
 loop:
 	for {