in python/src/internal.rs [87:111]
fn read_file_slice(&self, file_slice: &HudiFileSlice, py: Python) -> PyResult<PyObject> {
let mut file_group = FileGroup::new_with_base_file_name(
&file_slice.base_file_name,
&file_slice.partition_path,
)
.map_err(PythonError::from)?;
let log_file_names = &file_slice.log_file_names;
file_group
.add_log_files_from_names(log_file_names)
.map_err(PythonError::from)?;
let (_, file_slice) = file_group
.file_slices
.iter()
.next()
.ok_or_else(|| {
CoreError::FileGroup(format!(
"Failed to get file slice from file group: {:?}",
file_group
))
})
.map_err(PythonError::from)?;
rt().block_on(self.inner.read_file_slice(file_slice))
.map_err(PythonError::from)?
.to_pyarrow(py)
}