diff --git a/modules/beam/src/main/scala/com.snowplowanalytics.snowplow.enrich.beam/config.scala b/modules/beam/src/main/scala/com.snowplowanalytics.snowplow.enrich.beam/config.scala index fea021495..0ea927702 100644 --- a/modules/beam/src/main/scala/com.snowplowanalytics.snowplow.enrich.beam/config.scala +++ b/modules/beam/src/main/scala/com.snowplowanalytics.snowplow.enrich.beam/config.scala @@ -78,7 +78,7 @@ object config { resolver, args.optional("enrichments"), args.optional("labels"), - args.optional("sentry-dsn"), + args.asMap.get("sentry-dsn").map(_.mkString(",")), args.boolean("metrics", true) ) diff --git a/modules/beam/src/test/scala/com.snowplowanalytics.snowplow.enrich.beam/ConfigSpec.scala b/modules/beam/src/test/scala/com.snowplowanalytics.snowplow.enrich.beam/ConfigSpec.scala index e221b05b4..f513e4b45 100644 --- a/modules/beam/src/test/scala/com.snowplowanalytics.snowplow.enrich.beam/ConfigSpec.scala +++ b/modules/beam/src/test/scala/com.snowplowanalytics.snowplow.enrich.beam/ConfigSpec.scala @@ -122,6 +122,7 @@ class ConfigSpec extends AnyFreeSpec with EitherValues { ) } "which succeeds if --sentry-dsn is present" in { + val dsn = "https://foo.bar?stacktrace.app.packages=com.snowplowanalytics.snowplow.enrich.beam&tags=cloud:GCP,pipeline_name:dev,client_name:tests,region:ES&release=1.0.0&async=false" val args = Args( Array( "--job-name=j", @@ -130,11 +131,11 @@ class ConfigSpec extends AnyFreeSpec with EitherValues { "--bad=b", "--pii=p", "--resolver=r", - "--sentry-dsn=DSN" + s"--sentry-dsn=$dsn" ) ) EnrichConfig(args) shouldEqual Right( - EnrichConfig("j", "i", "o", "b", Some("p"), "r", None, None, Some("DSN"), true) + EnrichConfig("j", "i", "o", "b", Some("p"), "r", None, None, Some(dsn), true) ) } "which respects --metrics=false" in {