Reduced redis get to check job status

This commit is contained in:
Alfredo Cardigliano 2018-12-06 23:17:52 +01:00
parent dca54aa8e4
commit 4fb2dab9a7

View file

@ -792,13 +792,15 @@ local function setStuckJobsAsFailed()
local jobs = {}
local job_ids = ntop.getHashKeysCache(extraction_jobs_key) or {}
for id,_ in pairs(job_ids) do
for id,_ in pairsByKeys(job_ids, rev) do
local job_json = ntop.getHashCache(extraction_jobs_key, id)
local job = json.decode(job_json)
if job.status == "processing" then
job.status = "failed"
job.error_code = 9 -- stuck
ntop.setHashCache(extraction_jobs_key, job.id, json.encode(job))
ntop.setHashCache(extraction_jobs_key, job.id, json.encode(job))
else
break -- optimization
end
end
end