blob: c0d6c31b4629d0ea71bb4e3ae56492319f42d4b2 [file] [log] [blame] [edit]
--[[
Example lua script demonstrating the SLURM job_submit/lua interface.
This is only an example, not meant for use in its current form.
For use, this script should be copied into a file name "job_submit.lua"
in the same directory as the SLURM configuration file, slurm.conf.
--]]
function _limit_license_cnt(orig_string, license_name, max_count)
local i = 0
local j = 0
local val = 0
if orig_string == nil then
return 0
end
i, j, val = string.find(orig_string, license_name .. "%*(%d)")
-- if val ~= nil then log_info("name:%s count:%s", license_name, val) end
if val ~= nil and val + 0 > max_count then
return 1
end
return 0
end
--########################################################################--
--
-- SLURM job_submit/lua interface:
--
--########################################################################--
function slurm_job_submit ( job_desc, part_list, submit_uid )
setmetatable (job_desc, job_req_meta)
local bad_license_count = 0
bad_license_count = _limit_license_cnt(job_desc.licenses, "lscratcha", 1)
bad_license_count = _limit_license_cnt(job_desc.licenses, "lscratchb", 1) + bad_license_count
bad_license_count = _limit_license_cnt(job_desc.licenses, "lscratchc", 1) + bad_license_count
if bad_license_count > 0 then
log_info("slurm_job_submit: for user %d, invalid licenses value: %s",
job_desc.user_id, job_desc.licenses)
return slurm.ESLURM_INVALID_LICENSES
end
return 0
end
function slurm_job_modify ( job_desc, job_rec, part_list, modify_uid )
setmetatable (job_desc, job_req_meta)
setmetatable (job_rec, job_rec_meta)
local bad_license_count = 0
-- *** YOUR LOGIC GOES BELOW ***
bad_license_count = _limit_license_cnt(job_desc.licenses, "lscratcha", 1)
bad_license_count = _limit_license_cnt(job_desc.licenses, "lscratchb", 1) + bad_license_count
bad_license_count = _limit_license_cnt(job_desc.licenses, "lscratchc", 1) + bad_license_count
if bad_license_count > 0 then
log_info("slurm_job_modify: for job %u, invalid licenses value: %s",
job_rec.job_id, job_desc.licenses)
return slurm.ESLURM_INVALID_LICENSES
end
return 0
end
--########################################################################--
--
-- Initialization code:
--
-- Define functions for logging and accessing slurmctld structures
--
--########################################################################--
log_info = slurm.log_info
log_verbose = slurm.log_verbose
log_debug = slurm.log_debug
log_err = slurm.error
log_user = slurm.log_user
job_rec_meta = {
__index = function (table, key)
return _get_job_rec_field(table.job_rec_ptr, key)
end
}
job_req_meta = {
__index = function (table, key)
return _get_job_req_field(table.job_desc_ptr, key)
end,
__newindex = function (table, key, value)
return _set_job_req_field(table.job_desc_ptr, key, value)
end
}
part_rec_meta = {
__index = function (table, key)
return _get_part_rec_field(table.part_rec_ptr, key)
end
}
log_info("initialized")
return slurm.SUCCESS