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