——– BEGIN keys ——— local digest = KEYS local queued = KEYS local primed = KEYS local locked = KEYS local info = KEYS local changelog = KEYS local digests = KEYS ——– END keys ———

——– BEGIN lock arguments ——— local job_id = ARGV local pttl = tonumber(ARGV) local lock_type = ARGV local limit = tonumber(ARGV) local lock_score = ARGV ——– END lock arguments ———–

——– BEGIN injected arguments ——– local current_time = tonumber(ARGV) local debug_lua = tostring(ARGV) == “1” local max_history = tonumber(ARGV) local script_name = tostring(ARGV) .. “.lua” local redisversion = tostring(ARGV) ——— END injected arguments ———

——– BEGIN local functions ——– <%= include_partial “shared/_common.lua” %> ———- END local functions ———-

——– BEGIN delete.lua ——– log_debug(“BEGIN delete”, digest)

local redis_version = toversion(redisversion) local count = 0

log_debug(“ZREM”, digests, digest) count = count + redis.call(“ZREM”, digests, digest)

log_debug(“UNLINK”, digest, queued, primed, locked, info) count = count + redis.call(“UNLINK”, digest, queued, primed, locked, info)

log(“Deleted (” .. count .. “) keys”) log_debug(“END delete (” .. count .. “) keys for:”, digest)

return count ——– END delete.lua ——–