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