pass file_type to OpenWithXarray

pangeo-forge · Aug 31, 2023 · 8d472d5 · 8d472d5
1 parent ecaaded
commit 8d472d5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/feedstock/recipe.py b/feedstock/recipe.py
@@ -81,7 +81,9 @@ def expand(self, pcoll: beam.PCollection) -> beam.PCollection:
         open_kwargs={"block_size": 0, "client_kwargs": client_kwargs},
         max_concurrency=10,
     )
-    | OpenWithXarray()
+    | OpenWithXarray(
+        file_type=pattern.file_type,
+    )
     | Preprocess()
     | StoreToZarr(
         store_name="aqua-modis.zarr",