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