——– BEGIN keys ——— local queue = KEYS local schedule_set = KEYS local retry_set = KEYS ——– END keys ———
——– BEGIN Arguments ——— local digest = ARGV ——– END 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” ——— END injected arguments ———
——– BEGIN local functions ——– <%= include_partial “shared/_common.lua” %> <%= include_partial “shared/_delete_from_queue.lua” %> <%= include_partial “shared/_delete_from_sorted_set.lua” %> ———- END local functions ———-
——– BEGIN delete_job_by_digest.lua ——– local result = delete_from_queue(queue, digest) if result then
return result
end
result = delete_from_sorted_set(schedule_set, digest) if result then
return result
end
result = delete_from_sorted_set(retry_set, digest) return result ——– END delete_job_by_digest.lua ——–