Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
fix(pubsub): update quiescenceDur in failing e2e test (#3780)
  • Loading branch information
hongalex committed Mar 8, 2021
1 parent 3dd245d commit 97e6c69
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pubsub/internal/longtest/endtoend_test.go
Expand Up @@ -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)
Expand All @@ -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 {
Expand Down

0 comments on commit 97e6c69

Please sign in to comment.