Exception: Sq::Dbsync::Pipeline::Failure

Inherits:
StandardError
  • Object
show all
Defined in:
lib/sq/dbsync/pipeline.rb

Overview

Used to signal failed operations in a pipeline.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(wrapped, task) ⇒ Failure

Returns a new instance of Failure.



59
60
61
62
# File 'lib/sq/dbsync/pipeline.rb', line 59

def initialize(wrapped, task)
  @wrapped_exception = wrapped
  @task              = task
end

Instance Attribute Details

#taskObject (readonly)

The task that was being processed when this failure occurred.



57
58
59
# File 'lib/sq/dbsync/pipeline.rb', line 57

def task
  @task
end

#wrapped_exceptionObject (readonly)

The original exception that caused this failure.



54
55
56
# File 'lib/sq/dbsync/pipeline.rb', line 54

def wrapped_exception
  @wrapped_exception
end