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