lib/sidekiq/grouping/flusher_observer.rb in sidekiq-grouping-1.1.0 vs lib/sidekiq/grouping/flusher_observer.rb in sidekiq-grouping-1.2.0

- old
+ new

@@ -1,13 +1,19 @@ -class Sidekiq::Grouping::FlusherObserver - 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" - ) +# frozen_string_literal: true + +module Sidekiq + module Grouping + class FlusherObserver + 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 end end end