Class: MkitJob

Inherits:
ActiveRecord::Base
  • Object
show all
Defined in:
lib/mkit/app/model/mkit_job.rb

Constant Summary collapse

STATUS = 
%w{READY PROCESSING FAILED}

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.publish(*args) ⇒ Object 



16
17
18
19
20
21
 
# File 'lib/mkit/app/model/mkit_job.rb', line 16

def self.publish(*args)
  job = MkitJob.new(args[0])
  job.status = 'READY'
  job.save
  job
end

.take ⇒ Object 



12
13
14
 
# File 'lib/mkit/app/model/mkit_job.rb', line 12

def self.take
  MkitJob.where(status: 'READY').group(:service_id, :pod_id).take
end

Instance Method Details

#clean_up ⇒ Object 



45
46
 
# File 'lib/mkit/app/model/mkit_job.rb', line 45

def clean_up
end

#data ⇒ Object 



37
38
39
 
# File 'lib/mkit/app/model/mkit_job.rb', line 37

def data
  JSON.parse(self.payload)
end

#data=(opt = {}) ⇒ Object 



33
34
35
 
# File 'lib/mkit/app/model/mkit_job.rb', line 33

def data=(opt={})
  self.payload=opt.to_json
end

#done! ⇒ Object 



41
42
43
 
# File 'lib/mkit/app/model/mkit_job.rb', line 41

def done!
  self.destroy
end

#error! ⇒ Object 



28
29
30
31
 
# File 'lib/mkit/app/model/mkit_job.rb', line 28

def error!
  self.status='FAILED'
  self.save
end

#processing! ⇒ Object 



23
24
25
26
 
# File 'lib/mkit/app/model/mkit_job.rb', line 23

def processing!
  self.status='PROCESSING'
  self.save
end