in app/services/DynamoChannelTests.scala [339:363]
def updateStatuses(testNames: List[String], channel: Channel, status: Status): ZIO[ZEnv, DynamoError, Unit] = {
val items = testNames.map { testName =>
TransactWriteItem
.builder
.update(
Update
.builder
.tableName(tableName)
.key(buildKey(channel, testName))
.expressionAttributeValues(Map(
":status" -> AttributeValue.builder.s(status.toString).build,
":name" -> AttributeValue.builder.s(testName).build
).asJava)
.expressionAttributeNames(Map(
"#status" -> "status",
"#name" -> "name"
).asJava)
.updateExpression("SET #status = :status")
.conditionExpression("#name = :name") // only update if it already exists in the table
.build()
)
.build()
}
putAllBatchedTransaction(items)
}