diff --git a/rust/lance/src/io/exec/filtered_read.rs b/rust/lance/src/io/exec/filtered_read.rs
index 881497e9d0..67ca2f12e9 100644
--- a/rust/lance/src/io/exec/filtered_read.rs
+++ b/rust/lance/src/io/exec/filtered_read.rs
@@ -442,7 +442,7 @@ impl FilteredReadStream {
                     SpawnedTask::spawn(
                         Self::read_fragment(scoped_fragment, metrics, limit).in_current_span(),
                     )
-                    .map(|thread_result| thread_result.unwrap())
+                    .map(|thread_result| thread_result?)
                 }
             })
             .buffered(fragment_readahead);