Sha256: fcb02a41b69acd076a09eaa5afabf8b51b19d65435b27cd07bd26407c90bd50c

Contents?: true

Size: 250 Bytes

Versions: 6

Compression:

Stored size: 250 Bytes

Contents

local in_flight_key = KEYS[1]
local expire_at = ARGV[1]

local job = redis.call('get', in_flight_key)
if (not job) then return nil end

job = string.gsub(job, '("expire_at":)[0-9]*', '%1'..expire_at)
redis.call('set', in_flight_key, job)

return job

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
atomic-sidekiq-1.3.0 lib/atomic_sidekiq/atomic_operation/lua_scripts/heartbeat.lua
atomic-sidekiq-1.2.0 lib/atomic_sidekiq/atomic_operation/lua_scripts/heartbeat.lua
atomic-sidekiq-1.1.4 lib/atomic_sidekiq/atomic_operation/lua_scripts/heartbeat.lua
atomic-sidekiq-1.1.3 lib/atomic_sidekiq/atomic_operation/lua_scripts/heartbeat.lua
atomic-sidekiq-1.1.2 lib/atomic_sidekiq/atomic_operation/lua_scripts/heartbeat.lua
atomic-sidekiq-1.1.0 lib/atomic_sidekiq/atomic_operation/lua_scripts/heartbeat.lua