Strongly consistent local secondary index query

stronglyConsistentQuery.scala

private def recordsQuery =
    ScanamoOps.query(
      ScanamoQueryRequest(
        tableName,
        Some("incomplete_index"),
        'pkey -> s"$uuid.${schema.id}",
        new ScanamoQueryOptions(consistent = true, limit = Some(concurrencyLimit), None, None)
      )
    ).map {
      _.getItems.asScala.map { r =>
        DynamoFormat[BatchRecord].read(new AttributeValue().withM(r))
      }.toSet
    }

def nextRecords: Task[Set[BatchRecord]] = Task {
    Scanamo.exec(client)(recordsQuery).collect {
      case Right(r) => r
    }
  }