Skip to content

Commit

Permalink
Fix incorrect unpacking of job data
Browse files Browse the repository at this point in the history
  • Loading branch information
hamishforbes committed Aug 6, 2018
1 parent a72cf28 commit d66b2c6
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions queue.lua
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down

0 comments on commit d66b2c6

Please sign in to comment.