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