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