class SidekiqUniqueJobs::OnConflict::Reschedule
Strategy
to reschedule job on conflict
@author Mikael Henriksson <mikael@mhenrixon.com>
Public Class Methods
Source
# File lib/sidekiq_unique_jobs/on_conflict/reschedule.rb, line 15 def initialize(item, redis_pool = nil) super self.job_class = item[CLASS] end
@param [Hash] item sidekiq job hash
Calls superclass method
SidekiqUniqueJobs::OnConflict::Strategy::new
Public Instance Methods
Source
# File lib/sidekiq_unique_jobs/on_conflict/reschedule.rb, line 22 def call if sidekiq_job_class? if job_class.set(queue: item["queue"].to_sym).perform_in(schedule_in, *item[ARGS]) reflect(:rescheduled, item) else reflect(:reschedule_failed, item) end else reflect(:unknown_sidekiq_worker, item) end end
Create a new job from the current one.
This will mess up sidekiq stats because a new job is created
Source
# File lib/sidekiq_unique_jobs/on_conflict/reschedule.rb, line 34 def schedule_in job_class.get_sidekiq_options["schedule_in"] || 5 end