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::Merger::LOGGER_TAG}] Execution timed out\n"
      )
    elsif ex.present?
      @logger.error(
        "[#{Sidekiq::Merger::LOGGER_TAG}] Execution failed with error #{ex}\n"
      )
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
sidekiq-merger-0.1.0	lib/sidekiq/merger/logging_observer.rb
sidekiq-merger-0.0.12	lib/sidekiq/merger/logging_observer.rb
sidekiq-merger-0.0.11	lib/sidekiq/merger/logging_observer.rb
sidekiq-merger-0.0.10	lib/sidekiq/merger/logging_observer.rb
sidekiq-merger-0.0.9	lib/sidekiq/merger/logging_observer.rb
sidekiq-merger-0.0.8	lib/sidekiq/merger/logging_observer.rb
sidekiq-merger-0.0.7	lib/sidekiq/merger/logging_observer.rb
sidekiq-merger-0.0.6	lib/sidekiq/merger/logging_observer.rb