update to polars 1

bmsuisse · Jun 17, 2024 · 2c105fa · 2c105fa
1 parent a28b3e5
commit 2c105fa
Show file tree

Hide file tree

Showing 3 changed files with 103 additions and 94 deletions.
diff --git a/deltalake2db/polars.py b/deltalake2db/polars.py
@@ -173,7 +173,7 @@ def scan_delta_union(
         base_ds = pl.scan_parquet(
             fullpath, storage_options=delta_table._storage_options
         )
-        parquet_schema = base_ds.limit(0).schema
+        parquet_schema = base_ds.limit(0).collect_schema()
         selects = []
         for field in all_fields:
             pl_dtype = _get_type(field.type)