lib/atomic_sidekiq/atomic_operation/acknowledge.rb in atomic-sidekiq-1.0.0 vs lib/atomic_sidekiq/atomic_operation/acknowledge.rb in atomic-sidekiq-1.1.0

- old
+ new

@@ -1,10 +1,10 @@ module AtomicSidekiq module AtomicOperation class Acknowledge < Base - def perform(queue:, job:) + def perform(job:) redis do |conn| - conn.del(in_flight_job_key(queue, job)) + conn.del(in_flight_keymaker.job_key(job)) end end end end end