Contents

module AtomicSidekiq
  module AtomicOperation
    class Expire < Base
      EXPIRE_SCRIPT = File.read(
        File.join(File.dirname(__FILE__),
                  "./lua_scripts/expire.lua")
      )

      def initialize
        super(in_flight_keymaker: nil)
      end

      def perform(queue, in_flight_key, recover:)
        redis do |conn|
          conn.eval(
            EXPIRE_SCRIPT,
            [
              queue, # Queue Name
              in_flight_key, # Key of the inflight job being expired
            ],
            [
              Time.now.utc.to_i, # Current time
              recover, # Boolean flag: should it be recovered if expired
            ]
          )
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
atomic-sidekiq-1.3.0	lib/atomic_sidekiq/atomic_operation/expire.rb
atomic-sidekiq-1.2.0	lib/atomic_sidekiq/atomic_operation/expire.rb