1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00

Explicitly terminate processor before pushing back, #377

This commit is contained in:
Mike Perham 2012-08-29 09:04:59 -07:00
parent f3670c059a
commit bf97296fbf

View file

@ -129,6 +129,7 @@ module Sidekiq
# processor is an actor proxy and we can't call any methods
# that would go to the actor (since it's busy). Instead
# we'll use the object_id to track the worker's data here.
processor.terminate if processor.alive?
msg, queue = @in_progress[processor.object_id]
conn.lpush("queue:#{queue}", msg)
end