class SidekiqRobustJob::EnqueueConflictResolutionStrategy::DropSelf
Public Instance Methods
execute(job)
click to toggle source
# File lib/sidekiq_robust_job/enqueue_conflict_resolution_strategy/drop_self.rb, line 4 def execute(job) if jobs_repository.unprocessed_for_digest(job.digest, exclude_id: job.id).any? job.drop(dropped_by_job_id: job.id, clock: clock) end end