def test_read_all_from_avro_file_pattern(self):
    file_pattern = self._write_pattern(5)
    with TestPipeline() as p:
        assert_that(((p | Create([file_pattern])) | avroio.ReadAllFromAvro(use_fastavro=self.use_fastavro)), equal_to((self.RECORDS * 5)))
def test_read_all_from_avro_file_pattern(self):
    file_pattern = self._write_pattern(5)
    with TestPipeline() as p:
        assert_that(((p | Create([file_pattern])) | avroio.ReadAllFromAvro(use_fastavro=self.use_fastavro)), equal_to((self.RECORDS * 5)))