Contents

class ErrorProcessor < ETL::Processor::RowProcessor
  def initialize(control, configuration)
    super
  end
  def process(row)
    raise RuntimeError, "Generated error"
  end
end

set_error_threshold 1

source :in, {
  :type => :enumerable,
  :enumerable => [
    {:first_name => 'Bob',:last_name => 'Smith'},
    {:first_name => 'Joe', :last_name => 'Thompson'}
  ]
},
[
  :first_name,
  :last_name
]

after_read ErrorProcessor

Version data entries

6 entries across 6 versions & 4 rubygems

Version	Path
activewarehouse-etl-1.0.0	test/errors.ctl
activewarehouse-etl-1.0.0.rc1	test/errors.ctl
etl-0.9.5.rc1	spec/fixtures/errors.ctl
activewarehouse-etl-sgonyea-0.9.6	test/errors.ctl
activewarehouse-etl-0.9.5.rc1	test/errors.ctl
balinterdi-activewarehouse-etl-0.9.2	test/errors.ctl