class SidekiqRobustJob::EnqueueConflictResolutionStrategy::Replace
Public Instance Methods
execute(job)
click to toggle source
# File lib/sidekiq_robust_job/enqueue_conflict_resolution_strategy/replace.rb, line 4 def execute(job) jobs_repository.drop_unprocessed_jobs_by_digest( dropped_by_job_id: job.id, digest: job.digest, exclude_id: job.id ) end