@@ -586,7 +586,6 @@ func TestExactlyOnceDelivery_AckFailureErrorPermissionDenied(t *testing.T) {
586
586
}
587
587
588
588
func TestExactlyOnceDelivery_AckRetryDeadlineExceeded (t * testing.T ) {
589
- t .Parallel ()
590
589
ctx , cancel := context .WithCancel (context .Background ())
591
590
srv := pstest .NewServer (pstest .WithErrorInjection ("Acknowledge" , codes .Internal , "internal error" ))
592
591
client , err := NewClient (ctx , projName ,
@@ -621,7 +620,7 @@ func TestExactlyOnceDelivery_AckRetryDeadlineExceeded(t *testing.T) {
621
620
MinExtensionPeriod : 2 * time .Minute ,
622
621
}
623
622
// Override the default timeout here so this test doesn't take 10 minutes.
624
- exactlyOnceDeliveryRetryDeadline = 1 * time .Minute
623
+ exactlyOnceDeliveryRetryDeadline = 20 * time .Second
625
624
err = s .Receive (ctx , func (ctx context.Context , msg * Message ) {
626
625
ar := msg .AckWithResult ()
627
626
s , err := ar .Get (ctx )
@@ -682,7 +681,6 @@ func TestExactlyOnceDelivery_NackSuccess(t *testing.T) {
682
681
}
683
682
684
683
func TestExactlyOnceDelivery_NackRetry_DeadlineExceeded (t * testing.T ) {
685
- t .Parallel ()
686
684
ctx , cancel := context .WithCancel (context .Background ())
687
685
srv := pstest .NewServer (pstest .WithErrorInjection ("ModifyAckDeadline" , codes .Internal , "internal error" ))
688
686
client , err := NewClient (ctx , projName ,
@@ -718,7 +716,7 @@ func TestExactlyOnceDelivery_NackRetry_DeadlineExceeded(t *testing.T) {
718
716
MaxExtensionPeriod : 2 * time .Minute ,
719
717
}
720
718
// Override the default timeout here so this test doesn't take 10 minutes.
721
- exactlyOnceDeliveryRetryDeadline = 1 * time .Minute
719
+ exactlyOnceDeliveryRetryDeadline = 20 * time .Second
722
720
var once sync.Once
723
721
err = s .Receive (ctx , func (ctx context.Context , msg * Message ) {
724
722
once .Do (func () {
0 commit comments