Class: Sidekiq::Grouping::FlusherObserver

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq/grouping/flusher_observer.rb

Instance Method Summary collapse

Instance Method Details

#update(time, _result, ex) ⇒ Object 



2
3
4
5
6
7
8
9
10
11
12
 
# File 'lib/sidekiq/grouping/flusher_observer.rb', line 2

def update(time, _result, ex)
  if ex.is_a?(Concurrent::TimeoutError)
    Sidekiq::Grouping.logger.error(
      "[Sidekiq::Grouping] (#{time}) Execution timed out\n"
    )
  elsif ex.present?
    Sidekiq::Grouping.logger.error(
      "[Sidekiq::Grouping] Execution failed with error #{ex}\n"
    )
  end
end