Eventually consistent local secondary index query

eventuallyConsistentQuery.scala

val incompleteIndexTable: SecondaryIndex[BatchRecord] = BatchWorker.getIncompleteIndexTable(tableName)

private def recordsQuery =
    incompleteIndexTable
      .limit(concurrencyLimit)
      .query('pkey -> s"$uuid.${dp.id}")
      .map(_.toSet)
      
def nextRecords: Task[Set[BatchRecord]] = Task {
    Scanamo.exec(client)(recordsQuery).collect {
      case Right(r) => r
    }
  }