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