class SidekiqRobustJob::UniquenessStrategy::UntilExecuting
Public Instance Methods
execute(job)
click to toggle source
# File lib/sidekiq_robust_job/uniqueness_strategy/until_executing.rb, line 4 def execute(job) lock(job) do |locked| if locked drop_unprocessed_jobs(job) else job.reschedule and return end end perform_job_and_finalize(job) end