mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Whoa, reason is actually an Exception. Didn't know that.
This commit is contained in:
parent
09e0af6911
commit
a8c0e28bba
3 changed files with 6 additions and 6 deletions
|
@ -5,7 +5,7 @@
|
|||
Sidekiq process will exit immediately. This is to help prevent
|
||||
"stuck" Sidekiq processes which are running but don't appear to
|
||||
be doing any work. [#1194]
|
||||
- Sidekiq's testing framework is now dynamic. You can choose between
|
||||
- Sidekiq's testing behavior is now dynamic. You can choose between
|
||||
`inline` and `fake` behavior in your tests. [#1193]
|
||||
- The Retries table has a new column for the error message.
|
||||
- Sidekiq.default\_worker\_options allows you to configure default
|
||||
|
|
|
@ -1,8 +1,8 @@
|
|||
module Sidekiq
|
||||
module ExceptionHandler
|
||||
|
||||
def handle_exception(ex, ctxHash)
|
||||
Sidekiq.logger.warn ctxHash
|
||||
def handle_exception(ex, ctxHash={})
|
||||
Sidekiq.logger.warn(ctxHash) if !ctxHash.empty?
|
||||
Sidekiq.logger.warn ex
|
||||
Sidekiq.logger.warn ex.backtrace.join("\n")
|
||||
# This list of services is getting a bit ridiculous.
|
||||
|
|
|
@ -27,13 +27,13 @@ module Sidekiq
|
|||
|
||||
def actor_died(actor, reason)
|
||||
return if @done
|
||||
Sidekiq.logger.warn("Sidekiq died: #{reason}")
|
||||
Sidekiq.logger.warn("Cannot recover, process exiting")
|
||||
Sidekiq.logger.warn("Sidekiq died due to the following error, cannot recover, process exiting")
|
||||
handle_exception(reason)
|
||||
exit(1)
|
||||
end
|
||||
|
||||
def run
|
||||
watchdog('Launcher#stop') do
|
||||
watchdog('Launcher#run') do
|
||||
manager.async.start
|
||||
poller.async.poll(true)
|
||||
end
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue