def run()

in src/main/scala/com/gu/flexible/snapshotter/SnapshottingLambda.scala [26:36]

• 8 lines of code
• 1 McCabe index (conditional complexity)

  def run(input: SNSEvent): Unit = {
    implicit val config = SnapshotterConfig.resolve().get

    val requests = fromLambdaEvent(input)
    log.info(s"Processing message IDs: ${requests.map(_.id).mkString(", ")}")

    val results = snapshot(requests.map(_.content), config)
    val fin = SnapshottingLambda.logResults(results)

    FutureUtils.await(fin)
  }