Exception: CDC::Parallel::ProcessorExecutionError

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

Overview

Represents an exception raised inside a worker Ractor.

Worker exceptions are serialized before they cross the Ractor boundary and reconstructed as ‘ProcessorExecutionError` instances by ResultCollector.normalize. The original exception class name, message, and backtrace are exposed for diagnostics.

Examples:

Inspecting the original worker exception

result = runtime.process(event)
if result.failure?
  error = result.error
  error.original_class
  error.original_message
end

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(original_class:, original_message:, original_backtrace: []) ⇒ void

Create a reconstructed worker exception.

Parameters:

  • original_class (String) —

    Class name of the exception raised inside the worker.

  • original_message (String) —

    Message from the exception raised inside the worker.

  • original_backtrace (Array<String>) (defaults to: []) —

    Backtrace captured inside the worker.



68
69
70
71
72
73
74
75
 
# File 'lib/cdc/parallel/errors.rb', line 68

def initialize(original_class:, original_message:, original_backtrace: [])
  @original_class = original_class
  @original_message = original_message
  @original_backtrace = original_backtrace.freeze

  super("#{original_class}: #{original_message}")
  set_backtrace(@original_backtrace) unless @original_backtrace.empty?
end

Instance Attribute Details

#original_backtrace ⇒ Array<String> (readonly)

original exception backtrace.

Returns:

  • (Array<String>) —

    the current value of original_backtrace



56
57
58
 
# File 'lib/cdc/parallel/errors.rb', line 56

def original_backtrace
  @original_backtrace
end

#original_class ⇒ String (readonly)

original exception class name.

Returns:

  • (String) —

    the current value of original_class



56
57
58
 
# File 'lib/cdc/parallel/errors.rb', line 56

def original_class
  @original_class
end

#original_message ⇒ String (readonly)

original exception message.

Returns:

  • (String) —

    the current value of original_message



56
57
58
 
# File 'lib/cdc/parallel/errors.rb', line 56

def original_message
  @original_message
end