Class: Delayed::Job

Inherits:
ActiveRecord::Base
  • Object
show all
Defined in:
lib/delayed_job_extras/job.rb,
lib/delayed_job_test_enhancements.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.enqueue(obj, *args) ⇒ Object 



3
4
5
6
7
8
9
10
11
12
 
# File 'lib/delayed_job_test_enhancements.rb', line 3

def self.enqueue(obj, *args)
  if obj.respond_to?(:dj_object)
    if obj.dj_object.nil?
      obj.dj_object = Delayed::Job.new
      obj.dj_object.id = 1
    end
  end
  obj.perform
  obj.respond_to?(:dj_object) ? obj.dj_object : nil
end

.stats(start_date = 1.day.ago.beginning_of_day, end_date = Time.now.beginning_of_day) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/delayed_job_extras/job.rb', line 25

def stats(start_date = 1.day.ago.beginning_of_day, end_date = Time.now.beginning_of_day)
  workers = {}
  Delayed::Job.find_with_destroyed(:all, :select => :worker_class_name, :group => :worker_class_name).each do |dj|
    dj.worker_class_name = 'UNKNOWN' if dj.worker_class_name.blank?
    workers[dj.worker_class_name] = {} 
  end
  workers.each do |worker, stats|
    wname = (worker == 'UNKNOWN' ? nil : worker)
    stats[:total] = Delayed::Job.count_with_destroyed(:conditions => {:worker_class_name => wname})
    stats[:remaining] = Delayed::Job.count(:conditions => {:worker_class_name => wname})
    stats[:processed] = stats[:total] - stats[:remaining]
    stats[:failures] = Delayed::Job.count(:conditions => ['worker_class_name = ? and attempts > 1', wname])
    if start_date
      date_stats = {:start_date => start_date, :end_date => end_date}
      date_stats[:total] = Delayed::Job.count_with_destroyed(:conditions => ['worker_class_name = ? and (created_at > ? and created_at < ?)', wname, start_date, end_date])
      date_stats[:remaining] = Delayed::Job.count(:conditions => ['worker_class_name = ? and (created_at > ? and created_at < ?)', wname, start_date, end_date])
      date_stats[:processed] = date_stats[:total] - date_stats[:remaining]
      date_stats[:failures] = Delayed::Job.count(:conditions => ['worker_class_name = ? and attempts > 1 and (created_at > ? and created_at < ?)', wname, start_date, end_date])
      stats[:date_range] = date_stats
    end
    workers[worker] = stats
  end
  workers
end

Instance Method Details

#invoke_job_with_dj ⇒ Object 



16
17
18
19
 
# File 'lib/delayed_job_extras/job.rb', line 16

def invoke_job_with_dj
  payload_object.dj_object = self if payload_object.respond_to?(:dj_object)
  invoke_job_without_dj
end

#payload_object=(object) ⇒ Object 



11
12
13
14
 
# File 'lib/delayed_job_extras/job.rb', line 11

def payload_object=(object)
  self.worker_class_name = object.worker_class_name if object.respond_to?(:worker_class_name)
  self['handler'] = object.to_yaml
end