def takeCheckpointSnapshot()

in app/lib/RepoSnapshot.scala [214:223]


  def takeCheckpointSnapshot(checkpoint: Checkpoint): Future[CheckpointSnapshot] = for (
    possibleIdsTry <- checkpointSnapshoter.snapshot(checkpoint).trying
  ) yield {
    val objectIdTry = for (possibleIds <- possibleIdsTry) yield {
      possibleIds.map(repoLevelDetails.repoThreadLocal.reader().resolveExistingUniqueId).collectFirst {
        case Success(objectId) => objectId
      }
    }
    CheckpointSnapshot(checkpoint, objectIdTry)
  }