11import functools
2- from collections .abc import Callable , Mapping
2+ from collections .abc import Callable
33
44import pystac
55import xarray
7171
7272 mapper = fsspec .filesystem ("reference" , fo = refs ).get_mapper ()
7373 default_kwargs = {
74- "chunks" : {},
7574 "engine" : "zarr" ,
7675 "consolidated" : False ,
7776 }
8685 allow_kerchunk : bool = True ,
8786 ** kwargs ,
8887) -> xarray .Dataset :
89- default_kwargs : Mapping = {"chunks" : {}}
9088 open_kwargs = obj .extra_fields .get ("xarray:open_kwargs" , {})
9189
9290 storage_options = obj .extra_fields .get ("xarray:storage_options" , None )
@@ -107,23 +105,21 @@ def _(
107105 refs = patch_url (refs )
108106
109107 default_kwargs = {
110- ** default_kwargs ,
111108 "engine" : "kerchunk" ,
112109 }
113110 return xarray .open_dataset (refs , ** {** default_kwargs , ** open_kwargs , ** kwargs })
114111
115112 if obj .media_type == pystac .MediaType .COG :
116113 _import_optional_dependency ("rioxarray" )
117- default_kwargs = {** default_kwargs , "engine" : "rasterio" }
114+ default_kwargs = {"engine" : "rasterio" }
118115 elif obj .media_type in ["application/vnd+zarr" , "application/vnd.zarr" ]:
119116 _import_optional_dependency ("zarr" )
120117 zarr_kwargs = {}
121118 if "zarr:consolidated" in obj .extra_fields :
122119 zarr_kwargs ["consolidated" ] = obj .extra_fields ["zarr:consolidated" ]
123120 if "zarr:zarr_format" in obj .extra_fields :
124121 zarr_kwargs ["zarr_format" ] = obj .extra_fields ["zarr:zarr_format" ]
125-
126- default_kwargs = {** default_kwargs , ** zarr_kwargs , "engine" : "zarr" }
122+ default_kwargs = {** zarr_kwargs , "engine" : "zarr" }
127123 elif obj .media_type == "application/vnd.zarr+icechunk" :
128124 from xpystac ._icechunk import read_icechunk
129125
0 commit comments