diff --git a/daft/table/table_io.py b/daft/table/table_io.py index 9d8336b913..8ff1fc6c2d 100644 --- a/daft/table/table_io.py +++ b/daft/table/table_io.py @@ -453,7 +453,11 @@ def file_visitor(written_file, i=i): **kwargs, ) - data_dict: dict[str, Any] = {schema.column_names()[0]: visited_paths} + data_dict: dict[str, Any] = { + schema.column_names()[0]: Series.from_pylist(visited_paths, name=schema.column_names()[0]).cast( + DataType.string() + ) + } if partition_values is not None: partition_idx_series = Series.from_pylist(partition_idx).cast(DataType.int64())