Skip to content

Commit 59e9822

Browse files
committed
Fix indentation in _read_parquet function for schema unification logic
1 parent 92a1bdc commit 59e9822

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/flowerpower/fs/ext.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -950,9 +950,9 @@ def _read_parquet(
950950
# Unify schemas before concatenation if opt_dtypes or multiple tables
951951
if isinstance(tables, list):
952952
if len(tables) > 1:
953-
schemas = [t.schema for t in tables]
954-
unified_schema = unify_schemas_pa(schemas)
955-
tables = [cast_schema(t, unified_schema) for t in tables]
953+
schemas = [t.schema for t in tables]
954+
unified_schema = unify_schemas_pa(schemas)
955+
tables = [cast_schema(t, unified_schema) for t in tables]
956956
result = pa.concat_tables(
957957
[table for table in tables if table.num_rows > 0],
958958
promote_options="permissive",

0 commit comments

Comments
 (0)