From af6a1048f7f7785577f593c7a1cfab636d50e470 Mon Sep 17 00:00:00 2001 From: Hamish Date: Mon, 6 Aug 2018 11:26:53 +0100 Subject: [PATCH] Fix incorrect unpacking of job data --- queue.lua | 2 -- 1 file changed, 2 deletions(-) diff --git a/queue.lua b/queue.lua index 04e8497..a679984 100644 --- a/queue.lua +++ b/queue.lua @@ -324,10 +324,8 @@ function QlessQueue:pop(now, worker, count) -- queue itself and the priorities therein table.extend(jids, self.work.peek(count - #jids)) - local state for index, jid in ipairs(jids) do local job = Qless.job(jid) - state = unpack(job:data('state')) job:history(now, 'popped', {worker = worker}) -- Update the wait time statistics