mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
We cannot requeue unfinished jobs since the terminated actor cannot be accessed.
This commit is contained in:
parent
e2d65c11b1
commit
dec7472f33
2 changed files with 0 additions and 12 deletions
|
@ -55,13 +55,6 @@ module Sidekiq
|
|||
|
||||
after(timeout) do
|
||||
@busy.each(&:terminate)
|
||||
redis.with_connection do |conn|
|
||||
conn.multi do
|
||||
@busy.each do |busy|
|
||||
conn.lpush("queue:#{busy.queue}", busy.msg)
|
||||
end
|
||||
end
|
||||
end
|
||||
signal(:shutdown)
|
||||
end
|
||||
end
|
||||
|
@ -82,7 +75,6 @@ module Sidekiq
|
|||
if stopped?
|
||||
processor.terminate if processor.alive?
|
||||
else
|
||||
processor.msg = processor.queue = nil
|
||||
@ready << processor
|
||||
end
|
||||
dispatch
|
||||
|
@ -105,8 +97,6 @@ module Sidekiq
|
|||
if msg
|
||||
processor = @ready.pop
|
||||
@busy << processor
|
||||
processor.msg = msg
|
||||
processor.queue = queue
|
||||
processor.process!(MultiJson.decode(msg), queue)
|
||||
end
|
||||
!!msg
|
||||
|
|
|
@ -25,8 +25,6 @@ module Sidekiq
|
|||
end
|
||||
end
|
||||
|
||||
attr_accessor :msg, :queue
|
||||
|
||||
def initialize(boss)
|
||||
@boss = boss
|
||||
redis.sadd('workers', self)
|
||||
|
|
Loading…
Reference in a new issue