private def startExportProcess()

in src/main/scala/com/gu/zuora/fullexport/Cli.scala [22:29]


  private def startExportProcess(in: Input): Unit = {
    implicit val nonDeamonEc = ExecutionContext.fromExecutor(Executors.newCachedThreadPool)
    val overallResultF = Future.traverse(in.objects) { obj =>
      Future(retry(2)(exportObject(obj, in.beginningOfTime)))
        .andThen(logRunningStatus(obj))
    }
    logFinalResultWithDelay(overallResultF, in)
  }