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