Class: MandateJob

Inherits:
ApplicationJob
  • Object
show all
Defined in:
lib/mandate/rails/mandate_job.rb

Defined Under Namespace

Classes: MandateJobNeedsRequeuing, PreqJobNotFinishedError

Instance Method Summary collapse

Instance Method Details

#__guard_prereq_jobs__!(prereq_jobs) ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
57
58
59
 
# File 'lib/mandate/rails/mandate_job.rb', line 46

def __guard_prereq_jobs__!(prereq_jobs)
  return unless prereq_jobs.present?

  prereq_jobs.each do |job|
    jid = job[:job_id]

    # If the job is either in its queue, or in the retry queue
    # then we raise an exception to abort the job and retry later.
    if Sidekiq::Queue.new(job[:queue_name]).find_job(jid) ||
       Sidekiq::RetrySet.new.find_job(jid)
      raise PreqJobNotFinishedError, jid
    end
  end
end

#perform(cmd, *args, **kwargs) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/mandate/rails/mandate_job.rb', line 27

def perform(cmd, *args, **kwargs)
  __guard_prereq_jobs__!(kwargs.delete(:prereq_jobs))

  instance = cmd.constantize.new(*args, **kwargs)
  instance.define_singleton_method(:requeue_job!) { |wait| raise MandateJobNeedsRequeuing, wait }
  self.define_singleton_method :guard_against_deserialization_errors? do
    return true unless instance.respond_to?(:guard_against_deserialization_errors?)

    instance.guard_against_deserialization_errors?
  end

  instance.()
rescue MandateJobNeedsRequeuing => e
  cmd.constantize.defer(
    *args,
    **kwargs.merge(wait: e.wait)
  )
end