Skip to content

Commit

Permalink
Apply auto-formatting rules
Browse files Browse the repository at this point in the history
  • Loading branch information
weco-bot committed Jan 9, 2025
1 parent 46427de commit 75d7037
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 3 deletions.
6 changes: 4 additions & 2 deletions common/lambda/src/main/scala/weco/lambda/Downstream.scala
Original file line number Diff line number Diff line change
Expand Up @@ -54,15 +54,17 @@ object DownstreamBuilder extends Logging {

def buildDownstreamTarget(config: Config): DownstreamTarget = {
config.getStringOption("downstream.target") match {
case Some("sns") =>
case Some("sns") =>
val snsConfig = buildSNSConfig(config)
info(s"Building SNS downstream with config: $snsConfig")
SNS(snsConfig)
case Some("stdio") =>
info("Building StdOut downstream")
StdOut
case Some(unknownTarget) =>
throw new IllegalArgumentException(s"Invalid downstream target: $unknownTarget")
throw new IllegalArgumentException(
s"Invalid downstream target: $unknownTarget"
)
case None =>
warn("No downstream target specified, defaulting to StdOut")
StdOut
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,13 @@ package weco.pipeline.batcher.lib

import com.typesafe.config.Config
import weco.lambda.DownstreamBuilder.buildDownstreamTarget
import weco.lambda.{ApplicationConfig, DownstreamTarget, LambdaConfigurable, SNS, StdOut}
import weco.lambda.{
ApplicationConfig,
DownstreamTarget,
LambdaConfigurable,
SNS,
StdOut
}
import weco.messaging.typesafe.SNSBuilder.buildSNSConfig

case class BatcherConfig(
Expand Down

0 comments on commit 75d7037

Please sign in to comment.