Contents

module AtomicSidekiq
  module AtomicOperation
    class Acknowledge < Base
      def perform(queue:, job:)
        redis do |conn|
          conn.del(in_flight_job_key(queue, job))
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
atomic-sidekiq-1.0.0	lib/atomic_sidekiq/atomic_operation/acknowledge.rb