tests pass

snowplow · Sep 2, 2021 · bc33c83 · bc33c83
1 parent 843da11
commit bc33c83
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 12 deletions.
diff --git a/...s/common-fs2/src/main/scala/com/snowplowanalytics/snowplow/enrich/common/fs2/Enrich.scala b/...s/common-fs2/src/main/scala/com/snowplowanalytics/snowplow/enrich/common/fs2/Enrich.scala
@@ -112,15 +112,6 @@ object Enrich {
     val payload = ThriftLoader.toCollectorPayload(row, processor)
     val collectorTstamp = payload.toOption.flatMap(_.flatMap(_.context.timestamp).map(_.getMillis))
 
-    payload.toOption match {
-      case Some(Some(p)) =>
-        p.body match {
-          case Some(b) if b.contains("crash") => throw new RuntimeException("TEST CRASH")
-          case _ => System.out.println("foo")
-        }
-      case _ => System.out.println("bar")
-    }
-
     val result =
       for {
         _ <- Logger[F].debug(payloadToString(payload))

diff --git a/...c/test/scala/com/snowplowanalytics/snowplow/enrich/common/fs2/config/ConfigFileSpec.scala b/...c/test/scala/com/snowplowanalytics/snowplow/enrich/common/fs2/config/ConfigFileSpec.scala
@@ -64,9 +64,9 @@ class ConfigFileSpec extends Specification with CatsIO {
           io.Input.Kinesis.Retrieval.FanOut,
           io.Input.Kinesis.CheckpointSettings(1000, 10 seconds)
         ),
-        io.Output.Kinesis("enriched", "eu-central-1", None, 200.millis, 500, 5000000, io.Output.BackoffPolicy(10.millis, 10.seconds)),
-        Some(io.Output.Kinesis("pii", "eu-central-1", None, 200.millis, 500, 5000000, io.Output.BackoffPolicy(10.millis, 10.seconds))),
-        io.Output.Kinesis("bad", "eu-central-1", None, 200.millis, 500, 5000000, io.Output.BackoffPolicy(10.millis, 10.seconds)),
+        io.Output.Kinesis("enriched", "eu-central-1", None, 200.millis, 500, 5000000, io.Output.BackoffPolicy(100.millis, 10.seconds)),
+        Some(io.Output.Kinesis("pii", "eu-central-1", None, 200.millis, 500, 5000000, io.Output.BackoffPolicy(100.millis, 10.seconds))),
+        io.Output.Kinesis("bad", "eu-central-1", None, 200.millis, 500, 5000000, io.Output.BackoffPolicy(100.millis, 10.seconds)),
         Some(7.days),
         Some(
           io.Monitoring(