[CHORE] Revert parquet file_read metadata change

Eventual-Inc · Nov 22, 2023 · dee1648 · dee1648
1 parent ff218e7
commit dee1648
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/daft/execution/physical_plan.py b/daft/execution/physical_plan.py
@@ -111,7 +111,7 @@ def file_read(
             for i in range(len(vpartition)):
                 file_read_step = PartitionTaskBuilder[PartitionT](
                     inputs=[done_task.partition()],
-                    partial_metadatas=None,  # Child's metadata doesn't really matter for a file read
+                    partial_metadatas=[done_task.partition_metadata()],
                 ).add_instruction(
                     instruction=execution_step.ReadFile(
                         index=i,