good-job-execution.scala

import scala.concurrent.duration.Duration
import scala.concurrent.{Await, Future}

trait AsyncJob {
  def execute(): Future[Boolean]
}

class MyLongRunningJob(asyncJob: AsyncJob) extends Runnable {
  override def run(): Unit = {
    val result = Await.result(asyncJob.execute(), Duration.Inf)
    if (!result) {
      throw new RuntimeException("What the hell!")
    }
  }
}