

def get_pipeline(self):
    'Get the pipeline for this instance.'
    pipeline = []
    for name in self.processors:
        _class = self.resolve_processor(name)
        options = self.options.get(_class.name, {
            
        })
        options['row_limit'] = self.row_limit
        options['report_limit'] = self.report_limit
        options['report_stream'] = self.report_stream
        options['transform'] = self.transform
        options['fail_fast'] = self.fail_fast
        options['header_index'] = self.header_index
        options['report'] = self.report
        try:
            instance = _class(**options)
            pipeline.append(instance)
        except _class.RAISES as e:
            raise e
    return pipeline

dataset/ETHPy150Open frictionlessdata/goodtables/goodtables/pipeline/pipeline.py Pipeline.get_pipeline/original