def test_read_reantrant_with_splitting(self):
    file_name = self._write_data()
    source = _create_avro_source(file_name, use_fastavro=self.use_fastavro)
    splits = [split for split in source.split(desired_bundle_size=100000)]
    assert (len(splits) == 1)
    source_test_utils.assert_reentrant_reads_succeed((splits[0].source, splits[0].start_position, splits[0].stop_position))
def test_read_reantrant_with_splitting(self):
    file_name = self._write_data()
    source = _create_avro_source(file_name, use_fastavro=self.use_fastavro)
    splits = [split for split in source.split(desired_bundle_size=100000)]
    assert (len(splits) == 1)
    source_test_utils.assert_reentrant_reads_succeed((splits[0].source, splits[0].start_position, splits[0].stop_position))