in app/housekeeping/MarkOldUnusedBakesForDeletion.scala [39:65]
override def housekeep(): Unit = {
implicit val implicitPrismAgents: PrismData = prismAgents
implicit val implicitDynamo: Dynamo = dynamo
log.info(s"Started marking old, unused bakes for deletion")
val now = new DateTime()
val recipeIds = Recipes.list().map(_.id).toSet
val oldUnusedBakes = MarkOldUnusedBakesForDeletion.getOldUnusedBakes(
recipeIds,
now,
Bakes.list,
RecipeUsage.apply
)
if (oldUnusedBakes.nonEmpty)
log.info(
s"Found ${oldUnusedBakes.size} unused bakes over ${MarkOldUnusedBakesForDeletion.MAX_AGE} days old"
)
val bakesToMark =
oldUnusedBakes.take(MarkOldUnusedBakesForDeletion.BATCH_SIZE)
if (bakesToMark.nonEmpty)
log.info(s"Marking ${bakesToMark.size} unused bakes for deletion")
bakesToMark.foreach { bake =>
Bakes.markToDelete(bake.bakeId)
log.info(s"Marked ${bake.bakeId} for deletion")
}
}