Contents

class Sidekiq::Merger::LoggingObserver
  def initialize(logger)
    @logger = logger
  end

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

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
sidekiq-merger-0.0.5	lib/sidekiq/merger/logging_observer.rb
sidekiq-merger-0.0.4	lib/sidekiq/merger/logging_observer.rb
sidekiq-merger-0.0.1	lib/sidekiq/merger/logging_observer.rb