

def test_pipeline_row_limit_in_range(self):
    filepath = os.path.join(self.data_dir, 'row_limit_schema.csv')
    schema = os.path.join(self.data_dir, 'test_schema.json')
    options = {
        'schema': {
            'schema': schema,
        },
    }
    validator = Pipeline(filepath, processors=('schema',), row_limit=2, options=options)
    (result, report) = validator.run()
    self.assertEqual(len(report.generate()['results']), 0)
    self.assertEqual(validator.row_limit, 2)
    self.assertEqual(validator.pipeline[0].row_limit, 2)

dataset/ETHPy150Open frictionlessdata/goodtables/tests/test_schema.py TestSchemaProcessor.test_pipeline_row_limit_in_range/original