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