def batchGetReq()

in src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBRecovery.scala [541:550]

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

  def batchGetReq(items: JMap[String, KeysAndAttributes]) =
    new BatchGetItemRequest().withRequestItems(items).withReturnConsumedCapacity(ReturnConsumedCapacity.TOTAL)

  def logFailure[T](desc: String)(f: Future[T]): Future[T] =
    f.transform(
      identity(_),
      ex => {
        log.error(ex, "operation failed: " + desc)
        ex
      })