Sha256: 62d7ee9d0fe472f61ac63939f5b60055bc84714cfb147ae32a245a7e8b5137d7

Contents?: true

Size: 215 Bytes

Versions: 6

Compression:

Stored size: 215 Bytes

Contents

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

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
atomic-sidekiq-1.3.0 lib/atomic_sidekiq/atomic_operation/acknowledge.rb
atomic-sidekiq-1.2.0 lib/atomic_sidekiq/atomic_operation/acknowledge.rb
atomic-sidekiq-1.1.4 lib/atomic_sidekiq/atomic_operation/acknowledge.rb
atomic-sidekiq-1.1.3 lib/atomic_sidekiq/atomic_operation/acknowledge.rb
atomic-sidekiq-1.1.2 lib/atomic_sidekiq/atomic_operation/acknowledge.rb
atomic-sidekiq-1.1.0 lib/atomic_sidekiq/atomic_operation/acknowledge.rb