[BUG] Fix reading of logical types from Parquet files in s3

Eventual-Inc · Oct 10, 2024 · ab9a79e · ab9a79e
1 parent 73ff3f3
commit ab9a79e
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/daft-parquet/src/file.rs b/src/daft-parquet/src/file.rs
@@ -733,10 +733,9 @@ impl ParquetFileReader {
             })?
             .into_iter()
             .collect::<DaftResult<Vec<_>>>()?;
-        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(),
         )