in app/services/DynamoBanditData.scala [102:114]
def getDataForTest(testName: String, channel: String, sampleCount: Option[Int]): ZIO[ZEnv, DynamoError, BanditData] =
query(testName, channel)
.map { results =>
results.asScala
.map(item => dynamoMapToJson(item).as[TestSample])
.flatMap {
case Right(row) => Some(row)
case Left(error) =>
logger.error(s"Failed to decode item from Dynamo: ${error.getMessage}")
None
}
.toArray
}