private def failUnprocessedItems()

in formstack-baton-requests/src/main/scala/com/gu/identity/formstackbatonrequests/services/DynamoUpdateService.scala [47:57]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  private def failUnprocessedItems(batchWriteItemsResults: Seq[BatchWriteItemResult]): Either[Throwable, Seq[BatchWriteItemResult]] = {
    val unprocessedItems = batchWriteItemsResults.exists {
      !_.getUnprocessedItems.isEmpty
    }

    if (unprocessedItems) {
      Left(new Exception(s"Some items could not be written to DynamoDB: $batchWriteItemsResults"))
    } else {
      Right(batchWriteItemsResults)
    }
  }