Remove opening the file object

Let pyarrow handle opening the path using the filesystem. Signed-off-by: Max Z <max.zwiessele@babylonhealth.com>
feast-dev · Sep 15, 2022 · ea1a315 · ea1a315
1 parent 7bc1dff
commit ea1a315
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdk/python/feast/infra/offline_stores/file_source.py b/sdk/python/feast/infra/offline_stores/file_source.py
@@ -161,7 +161,7 @@ def get_table_column_names_and_types(
             schema = ParquetDataset(path).schema.to_arrow_schema()
         else:
             schema = ParquetDataset(
-                filesystem.open_input_file(path), filesystem=filesystem
+                path, filesystem=filesystem
             ).schema
 
         return zip(schema.names, map(str, schema.types))