class Sidekiq::Grouping::FlusherObserver

Public Instance Methods

update(time, _result, exception) click to toggle source
# File lib/sidekiq/grouping/flusher_observer.rb, line 6
def update(time, _result, exception)
  if exception.is_a?(Concurrent::TimeoutError)
    Sidekiq::Grouping.logger.error(
      "[Sidekiq::Grouping] (#{time}) Execution timed out\n"
    )
  elsif exception.present?
    Sidekiq::Grouping.logger.error(
      "[Sidekiq::Grouping] Execution failed with error #{exception}\n"
    )
  end
end