in riff-raff/app/deployment/Deployments.scala [196:217]
def update(wrapper: MessageWrapper): Unit = {
Option(library()(wrapper.context.deployId)) foreach { recordAgent =>
recordAgent send { record =>
val updated = record + wrapper
documentStoreConverter.saveMessage(wrapper)
if (record.state != updated.state) {
documentStoreConverter.updateDeployStatus(updated)
}
if (
record.totalTasks != updated.totalTasks ||
record.completedTasks != updated.completedTasks ||
record.hasWarnings != updated.hasWarnings
) {
documentStoreConverter.updateDeploySummary(updated)
}
if (updated.isDone) {
cleanup(record.uuid)
}
updated
}
}
}