apps/workbench/app/models/job.rb

   1 class Job < ArvadosBase
   2   def self.goes_in_projects?
   3     true
   4   end
   5
   6   def content_summary
   7     "#{script} job"
   8   end
   9
  10   def attribute_editable? attr, *args
  11     if attr.to_sym == :description
  12       super && attr.to_sym == :description
  13     else
  14       false
  15     end
  16   end
  17
  18   def self.creatable?
  19     false
  20   end
  21
  22   def default_name
  23     if script
  24       x = "\"#{script}\" job"
  25     else
  26       x = super
  27     end
  28     if finished_at
  29       x += " finished #{finished_at.strftime('%b %-d')}"
  30     elsif started_at
  31       x += " started #{started_at.strftime('%b %-d')}"
  32     elsif created_at
  33       x += " submitted #{created_at.strftime('%b %-d')}"
  34     end
  35   end
  36
  37   def cancel
  38     arvados_api_client.api "jobs/#{self.uuid}/", "cancel", {}
  39   end
  40
  41   def self.queue_size
  42     arvados_api_client.api("jobs/", "queue_size", {"_method"=> "GET"})[:queue_size] rescue 0
  43   end
  44
  45   def self.queue
  46     arvados_api_client.unpack_api_response arvados_api_client.api("jobs/", "queue", {"_method"=> "GET"})
  47   end
  48
  49   # The 'job' parameter can be either a Job model object, or a hash containing
  50   # the same fields as a Job object (such as the :job entry of a pipeline
  51   # component).
  52   def self.state job
  53     # This has a valid state method on it so call that
  54     if job.respond_to? :state and job.state
  55       return job.state
  56     end
  57
  58     # Figure out the state based on the other fields.
  59     if job[:cancelled_at]
  60       "Cancelled"
  61     elsif job[:success] == false
  62       "Failed"
  63     elsif job[:success] == true
  64       "Complete"
  65     elsif job[:running] == true
  66       "Running"
  67     else
  68       "Queued"
  69     end
  70   end
  71
  72   def textile_attributes
  73     [ 'description' ]
  74   end
  75 end