diff --git a/testkit/src/main/scala/com/commercetools/queue/testkit/QueueClientSuite.scala b/testkit/src/main/scala/com/commercetools/queue/testkit/QueueClientSuite.scala
index 79db935..dd515b9 100644
--- 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")))