Tweak timeouts

topfreegames · Jun 17, 2024 · 2aacdb2 · 2aacdb2
1 parent 649f05c
commit 2aacdb2
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/e2e/apns_e2e_test.go b/e2e/apns_e2e_test.go
@@ -78,7 +78,7 @@ func (s *ApnsE2ETestSuite) setupApnsPusher() (
 func (s *ApnsE2ETestSuite) TestSimpleNotification() {
 	p, mockApnsClient, statsdClientMock, responsesChannel := s.setupApnsPusher()
 	go p.Start(context.Background())
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
 		"bootstrap.servers": s.config.Queue.Brokers,
@@ -148,7 +148,7 @@ func (s *ApnsE2ETestSuite) TestSimpleNotification() {
 func (s *ApnsE2ETestSuite) TestNotificationRetry() {
 	p, mockApnsClient, statsdClientMock, responsesChannel := s.setupApnsPusher()
 	go p.Start(context.Background())
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
 		"bootstrap.servers": s.config.Queue.Brokers,
@@ -238,7 +238,7 @@ func (s *ApnsE2ETestSuite) TestNotificationRetry() {
 func (s *ApnsE2ETestSuite) TestRetryLimit() {
 	p, mockApnsClient, statsdClientMock, responsesChannel := s.setupApnsPusher()
 	go p.Start(context.Background())
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
 		"bootstrap.servers": s.config.Queue.Brokers,
@@ -311,7 +311,7 @@ func (s *ApnsE2ETestSuite) TestRetryLimit() {
 func (s *ApnsE2ETestSuite) TestMultipleNotifications() {
 	p, mockApnsClient, statsdClientMock, responsesChannel := s.setupApnsPusher()
 	go p.Start(context.Background())
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	notificationsToSend := 10
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
@@ -394,7 +394,7 @@ func (s *ApnsE2ETestSuite) TestConsumeMessagesBeforeExiting() {
 	ctx := context.Background()
 	ctx, cancel := context.WithCancel(ctx)
 	go p.Start(ctx)
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	notificationsToSend := 3
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
@@ -485,7 +485,7 @@ func (s *ApnsE2ETestSuite) TestConsumeMessagesBeforeExitingWithRetries() {
 	ctx := context.Background()
 	ctx, cancel := context.WithCancel(ctx)
 	go p.Start(ctx)
-	time.Sleep(wait * 3)
+	time.Sleep(wait * 2)
 
 	producer, err := kafka.NewProducer(&kafka.ConfigMap{
 		"bootstrap.servers": s.config.Queue.Brokers,

diff --git a/e2e/utils_test.go b/e2e/utils_test.go
@@ -3,7 +3,7 @@ package e2e
 import "time"
 
 const (
-	wait              = 10 * time.Second
+	wait              = 15 * time.Second
 	timeout           = 1 * time.Minute
 	apnsTopicTemplate = "push-%s_apns-single"
 	gcmTopicTemplate  = "push-%s_gcm-single"