Wait for more

commercetools · Sep 17, 2024 · 45a6e6c · 45a6e6c
1 parent 57e5bc9
commit 45a6e6c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/testkit/src/main/scala/com/commercetools/queue/testkit/QueueClientSuite.scala b/testkit/src/main/scala/com/commercetools/queue/testkit/QueueClientSuite.scala
@@ -15,6 +15,7 @@ import scala.concurrent.duration._
  * This is used in integration tests for the various implemented queue providers.
  */
 abstract class QueueClientSuite extends CatsEffectSuite {
+  override def munitTimeout: Duration = 1.minute
 
   def optBoolean(varName: String): IO[Option[Boolean]] =
     optString(varName).map(_.map(_.toBoolean))
@@ -111,7 +112,7 @@ abstract class QueueClientSuite extends CatsEffectSuite {
         _ <- assertIO(puller.pullBatch(1, 1.second), Chunk.empty)
         _ <- IO.sleep(2.seconds)
         msg <- puller
-          .pullBatch(1, 1.second)
+          .pullBatch(1, 10.second) // waiting 10 sec, some cloud provider is really slow in non-premium plans
           .map(_.head.getOrElse(fail("expected a message, got nothing.")))
         _ = assertEquals(msg.rawPayload, "delayed message")
         _ = assert(metadataContains(msg.metadata, Map("metadata-key" -> "value")))