class Sidekiq::Merger::LoggingObserver
Public Class Methods
new(logger)
click to toggle source
# File lib/sidekiq/merger/logging_observer.rb, line 2 def initialize(logger) @logger = logger end
Public Instance Methods
update(time, _result, ex)
click to toggle source
# File lib/sidekiq/merger/logging_observer.rb, line 6 def update(time, _result, ex) if ex.is_a?(Concurrent::TimeoutError) @logger.error( "[#{Sidekiq::Merger::LOGGER_TAG}] Execution timed out\n" ) elsif ex.present? @logger.error( "[#{Sidekiq::Merger::LOGGER_TAG}] Execution failed with error #{ex}\n" ) end end