Contents

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"
      )
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
sidekiq-grouping-1.1.0	lib/sidekiq/grouping/flusher_observer.rb
sidekiq-grouping-1.0.10	lib/sidekiq/grouping/flusher_observer.rb
sidekiq-grouping-1.0.9	lib/sidekiq/grouping/flusher_observer.rb
sidekiq-grouping-1.0.8	lib/sidekiq/grouping/flusher_observer.rb
sidekiq-grouping-1.0.7	lib/sidekiq/grouping/flusher_observer.rb
sidekiq-grouping-1.0.6	lib/sidekiq/grouping/flusher_observer.rb