class AtomicSidekiq::AtomicOperation::Requeue
Public Instance Methods
perform(queue:, job:)
click to toggle source
# File lib/atomic_sidekiq/atomic_operation/requeue.rb, line 4 def perform(queue:, job:) redis do |conn| requeue(conn, queue: queue, job: job) end end
Private Instance Methods
requeue(conn, queue:, job:)
click to toggle source
# File lib/atomic_sidekiq/atomic_operation/requeue.rb, line 12 def requeue(conn, queue:, job:) conn.multi do conn.rpush(queue, job) conn.del(in_flight_keymaker.job_key(job)) end end