Advertisement
NLinker

Untitled

Nov 12th, 2013
199
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1.  case class JobResolved(jobId: Int,
  2.                        jobType: JobTypeResolved,
  3.                        fireTime: DateTime,
  4.                        tempFiles: Seq[String],
  5.                        status: Status,
  6.                        retry: Int)
  7.  
  8.     val tempDir = util.Files.createTempDir()
  9.     val ops = for {
  10.       jobResolved <- Resolver.resolve(job)
  11.       extractor   <- Try(Extractor(jobResolved))
  12.       handler     <- Try(Handler(jobResolved, tempDir))
  13.     } yield extractor.apply(handler)
  14.     ops match {
  15.       case Success(seq) => {
  16.         logger.debug("Created new reporting files: ", seq)
  17.         ...
  18.       }
  19.       case Failure(exn) => {
  20.         logger.error("Unable to process the job: ", ex)
  21.         ...
  22.       }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement