def test_read_all_from_avro_single_file(self):
    path = self._write_data()
    with TestPipeline() as p:
        assert_that(((p | Create([path])) | avroio.ReadAllFromAvro(use_fastavro=self.use_fastavro)), equal_to(self.RECORDS))
def test_read_all_from_avro_single_file(self):
    path = self._write_data()
    with TestPipeline() as p:
        assert_that(((p | Create([path])) | avroio.ReadAllFromAvro(use_fastavro=self.use_fastavro)), equal_to(self.RECORDS))