From 88a464dc9c311d6ef3b15ce909023d5dd10cdd93 Mon Sep 17 00:00:00 2001 From: colmsnowplow Date: Wed, 12 Jun 2024 12:46:19 +0100 Subject: [PATCH] Extend timeout for BaseProcessingSpec --- .../stream/common/processing/BaseProcessingSpec.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/common-transformer-stream/src/test/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/stream/common/processing/BaseProcessingSpec.scala b/modules/common-transformer-stream/src/test/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/stream/common/processing/BaseProcessingSpec.scala index 5db8e5b60..c4768b665 100644 --- a/modules/common-transformer-stream/src/test/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/stream/common/processing/BaseProcessingSpec.scala +++ b/modules/common-transformer-stream/src/test/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/stream/common/processing/BaseProcessingSpec.scala @@ -43,7 +43,7 @@ trait BaseProcessingSpec extends Specification { checkpointRef <- Ref.of[IO, Int](0) completionsRef <- Ref.of[IO, Vector[String]](Vector.empty) queueBadSink <- Ref.of[IO, Vector[String]](Vector.empty) - _ <- TestApplication.run(args, completionsRef, checkpointRef, queueBadSink, input).timeout(60.seconds) + _ <- TestApplication.run(args, completionsRef, checkpointRef, queueBadSink, input).timeout(120.seconds) checkpointed <- checkpointRef.get completions <- completionsRef.get badrows <- queueBadSink.get