Skip to content

Instantly share code, notes, and snippets.

Created Aug 30, 2019
What would you like to do?
The Lua Script to Remove A job
local job_id = ARGV[1]
-- Source the jobs metadata for some accounting
metadata_key = 'jobs:' .. job_id
local job_metadata ='HMGET', metadata_key, 'tenant_id', 'queue')
local tenant_id = job_metadata[1]
local queue = job_metadata[2]
-- cleanup the job's running state
local running_jobs = queue .. '_running_jobs:' .. tenant_id'SREM', running_jobs, job_id)
-- if rescheduling this job made the tenant runnable, mark them as such
local limit = tonumber('HGET', 'tenant_limits', queue))
local runing_jobs_count ='SCARD', running_jobs)
local pending_jobs = queue .. '_pending_jobs:' .. tenant_id
local pending_jobs_count ='LLEN', pending_jobs)
if (runing_jobs_count < limit and pending_jobs_count > 0) then
local runnable_tenants = queue .. '_runnable_tenants''SADD', runnable_tenants, tenant_id)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment