Error Stages

To add an error stage to a pipeline, use the streamsets.sdk.sdc_models.PipelineBuilder.add_error_stage() method:

discard = builder.add_error_stage('Discard')

By default, the streamsets.sdk.sdc_models.PipelineBuilder instance will use ‘Discard’ if no error stage is specified.