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