class SidekiqFakeScheduler::JobWrapper

Public Class Methods

new(job) click to toggle source
# File lib/sidekiq_fake_scheduler/job_wrapper.rb, line 5
def initialize(job)
  @job = job
end

Public Instance Methods

perform() click to toggle source
# File lib/sidekiq_fake_scheduler/job_wrapper.rb, line 16
def perform
  delete_from_queues
  worker_class.new.perform(*@job['args'])
end
try_perform() click to toggle source
# File lib/sidekiq_fake_scheduler/job_wrapper.rb, line 9
def try_perform
  return false if @job.key?('at') && @job['at'] > Time.now.to_f

  perform
  true
end

Private Instance Methods

delete_from_queues() click to toggle source
# File lib/sidekiq_fake_scheduler/job_wrapper.rb, line 27
def delete_from_queues
  Sidekiq::Queues[@job['queue']].delete @job
  worker_class.jobs.delete @job
end
worker_class() click to toggle source
# File lib/sidekiq_fake_scheduler/job_wrapper.rb, line 23
def worker_class
  Object.const_get @job['class']
end