diff --git a/daft/table/table.py b/daft/table/table.py index eb39859814..054ba099f9 100644 --- a/daft/table/table.py +++ b/daft/table/table.py @@ -475,6 +475,8 @@ def read_parquet_into_pyarrow( multithreaded_io=multithreaded_io, coerce_int96_timestamp_unit=coerce_int96_timestamp_unit._timeunit, ) + if len(metadata) == 0: + metadata = None schema = pa.schema(fields, metadata=metadata) columns = [pa.chunked_array(c) for c in columns] # type: ignore return pa.table(columns, schema=schema)