Exception: CDC::Sidekiq::ProcessorFailureError

Inherits:
Error
  • Object
show all
Defined in:
lib/cdc/sidekiq/errors.rb

Overview

Raised when processor execution returns one or more failed results.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(failures) ⇒ void

Parameters:

  • failures (Array<Object>) —

    failed processor results that should be exposed to Sidekiq retry handling.



21
22
23
24
 
# File 'lib/cdc/sidekiq/errors.rb', line 21

def initialize(failures)
  @failures = failures.freeze
  super("CDC processor failed for #{failures.length} item(s)")
end

Instance Attribute Details

#failures ⇒ Array<Object> (readonly)

Returns failed processor results that triggered the error.

Returns:

  • (Array<Object>) —

    failed processor results that triggered the error.



17
18
19
 
# File 'lib/cdc/sidekiq/errors.rb', line 17

def failures
  @failures
end