diff --git a/src/daft-parquet/src/lib.rs b/src/daft-parquet/src/lib.rs index a23af268f8..374ce38375 100644 --- a/src/daft-parquet/src/lib.rs +++ b/src/daft-parquet/src/lib.rs @@ -1,6 +1,7 @@ #![feature(async_closure)] #![feature(let_chains)] #![feature(result_flattening)] +#![feature(result_option_inspect)] use common_error::DaftError; use snafu::Snafu; diff --git a/src/daft-parquet/src/read_planner.rs b/src/daft-parquet/src/read_planner.rs index 942f593301..d98a475366 100644 --- a/src/daft-parquet/src/read_planner.rs +++ b/src/daft-parquet/src/read_planner.rs @@ -107,6 +107,7 @@ impl RangeCacheEntry { .await .map_err(|e| daft_io::Error::JoinError { source: e }) .flatten() + .inspect_err(|e| log::warn!("Range fetch error: {}", e)) .map_err(Arc::new); let sliced = v .as_ref()