in src/main/scala/com/gu/flexible/snapshotter/logic/FutureUtils.scala [12:19]
def await[T](future: Future[T]) = {
try {
Await.ready(future, 120 seconds)
} catch {
case e: TimeoutException => log.error("Timed out whilst waiting for futures to complete", e)
case e: InterruptedException => log.error("Interrupted whilst waiting for future to complete", e)
}
}