diff --git a/feedstock/recipe.py b/feedstock/recipe.py index 85079cf..f1323e8 100644 --- 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",