

def test_pipeline_report_stream_valid(self):
    filepath = os.path.join(line.data_dir, 'valid.csv')
    report_stream = io.TextIOWrapper(io.BufferedRandom(io.BytesIO()))
    options = {
        
    }
    validator = Pipeline(filepath, processors=('schema',), report_stream=report_stream, options=options)
    (result, report) = validator.run()
    self.assertEqual(len(report.generate()['results']), 0)
    report_stream.seek(0)
    for line in report_stream:
        self.assertTrue(json.loads(line.rstrip('\n')))

dataset/ETHPy150Open frictionlessdata/goodtables/tests/test_schema.py TestSchemaProcessor.test_pipeline_report_stream_valid/VarMisuse@18/23 `self`->`line`