def updateStatuses()

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)
  }