From b1a5ba1ec42cd358ab964dd755cb80f3e2a01cb9 Mon Sep 17 00:00:00 2001 From: Oguzhan Unlu Date: Wed, 22 May 2024 15:18:56 +0300 Subject: [PATCH] Fix config tests --- .../snowplowanalytics/snowplow/enrich/kafka/ConfigSpec.scala | 4 ++-- .../snowplow/enrich/kinesis/ConfigSpec.scala | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/modules/kafka/src/test/scala/com/snowplowanalytics/snowplow/enrich/kafka/ConfigSpec.scala b/modules/kafka/src/test/scala/com/snowplowanalytics/snowplow/enrich/kafka/ConfigSpec.scala index 054c5916c..71d8178ce 100644 --- a/modules/kafka/src/test/scala/com/snowplowanalytics/snowplow/enrich/kafka/ConfigSpec.scala +++ b/modules/kafka/src/test/scala/com/snowplowanalytics/snowplow/enrich/kafka/ConfigSpec.scala @@ -92,7 +92,7 @@ class ConfigSpec extends Specification with CatsEffect { ) ) ), - io.Concurrency(256, 1), + io.Concurrency(256, 8), Some(7.days), io.RemoteAdapterConfigs( 10.seconds, @@ -202,7 +202,7 @@ class ConfigSpec extends Specification with CatsEffect { ) ) ), - io.Concurrency(256, 1), + io.Concurrency(256, 8), None, io.RemoteAdapterConfigs( 10.seconds, diff --git a/modules/kinesis/src/test/scala/com/snowplowanalytics/snowplow/enrich/kinesis/ConfigSpec.scala b/modules/kinesis/src/test/scala/com/snowplowanalytics/snowplow/enrich/kinesis/ConfigSpec.scala index c7ad3136b..350342327 100644 --- a/modules/kinesis/src/test/scala/com/snowplowanalytics/snowplow/enrich/kinesis/ConfigSpec.scala +++ b/modules/kinesis/src/test/scala/com/snowplowanalytics/snowplow/enrich/kinesis/ConfigSpec.scala @@ -81,7 +81,7 @@ class ConfigSpec extends Specification with CatsEffect { None ) ), - io.Concurrency(256, 1), + io.Concurrency(256, 8), Some(7.days), io.RemoteAdapterConfigs( 10.seconds, @@ -175,7 +175,7 @@ class ConfigSpec extends Specification with CatsEffect { None ) ), - io.Concurrency(256, 1), + io.Concurrency(256, 8), None, io.RemoteAdapterConfigs( 10.seconds,