From d66b2c6e6bdec1785632ed56125a1a9785117f11 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 | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/queue.lua b/queue.lua index 04e8497..63cb441 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 @@ -908,7 +906,7 @@ function QlessQueue:invalidate_locks(now, count) ['message'] = 'Job exhausted retries in queue "' .. self.name .. '"', ['when'] = now, - ['worker'] = unpack(job:data('worker')) + ['worker'] = job:data('worker') })) -- Add this type of failure to the list of failures