diff --git a/src/daft-parquet/src/file.rs b/src/daft-parquet/src/file.rs index 02b57ed6f9..8c582dd24e 100644 --- a/src/daft-parquet/src/file.rs +++ b/src/daft-parquet/src/file.rs @@ -733,10 +733,9 @@ impl ParquetFileReader { })? .into_iter() .collect::>>()?; - let daft_schema = daft_core::prelude::Schema::try_from(self.arrow_schema.as_ref())?; Table::new_with_size( - daft_schema, + Schema::new(all_series.iter().map(|s| s.field().clone()).collect())?, all_series, self.row_ranges.as_ref().iter().map(|rr| rr.num_rows).sum(), )