in app/com/gu/floodgate/reindex/ProgressTracker.scala [75:94]
private def updateProgress(result: Try[WSResponse], contentSource: ContentSource, runningJob: RunningJob): Unit = {
result match {
case Success(response) =>
response.status match {
case 200 => onSuccess(response, contentSource, runningJob)
case _ => {
logger.warn(
s"Content source with id: ${contentSource.id} returned a http ${response.status} response to a progress request: ${response.body}"
)
onFailure(contentSource, runningJob)
}
}
case Failure(e) => {
logger.error(
s"Failure while calling content source: ${contentSource.id} for progress request: ${e.getMessage}"
)
onFailure(contentSource, runningJob)
}
}
}