apps/workbench/app/models/job_work_unit.rb

   1 class JobWorkUnit < ProxyWorkUnit
   2   def children
   3     # Job tasks
   4     uuid = (self.proxied.uuid if self.proxied.respond_to?(:uuid)) || self.proxied[:uuid]
   5     tasks = JobTask.filter([['job_uuid', '=', uuid]]).results
   6     items = []
   7     tasks.each do |t|
   8       items << t.work_unit("task #{items.size}")
   9     end
  10
  11     # Jobs submitted by this job  --  TBD
  12
  13     items
  14   end
  15
  16   def progress
  17     state = (self.proxied.state if self.proxied.respond_to?(:state)) || self.proxied[:state]
  18     if state == 'Complete'
  19       return 1.0
  20     end
  21
  22     tasks_summary = (self.proxied.tasks_summary if self.proxied.respond_to?(:tasks_summary)) || self.proxied[:tasks_summary]
  23     failed = tasks_summary[:failed] || 0 rescue 0
  24     done = tasks_summary[:done] || 0 rescue 0
  25     running = tasks_summary[:running] || 0 rescue 0
  26     todo = tasks_summary[:todo] || 0 rescue 0
  27     if done + running + failed + todo > 0
  28       total_tasks = done + running + failed + todo
  29       (done+failed).to_f / total_tasks
  30     else
  31       0.0
  32     end
  33   end
  34
  35   def docker_image
  36     (self.proxied.docker_image_locator if self.proxied.respond_to?(:docker_image_locator)) || self.proxied[:docker_image_locator]
  37   end
  38
  39   def nondeterministic
  40     (self.proxied.nondeterministic if self.proxied.respond_to?(:nondeterministic)) || self.proxied[:nondeterministic]
  41   end
  42
  43   def priority
  44     (self.proxied.priority if self.proxied.respond_to?(:priority)) || self.proxied[:priority]
  45   end
  46
  47   def log_collection
  48     (self.proxied.log if self.proxied.respond_to?(:log)) || self.proxied[:log]
  49   end
  50
  51   def output
  52     (self.proxied.output if self.proxied.respond_to?(:output)) || self.proxied[:output]
  53   end
  54
  55   def uri
  56     uuid = (self.proxied.uuid if self.proxied.respond_to?(:uuid)) || self.proxied[:uuid]
  57     "/jobs/#{uuid}"
  58   end
  59
  60   def child_summary
  61     (self.proxied.tasks_summary if self.proxied.respond_to?(:tasks_summary)) || self.proxied[:tasks_summary]
  62   end
  63
  64   def title
  65     "job"
  66   end
  67 end