Skip to content

Commit

Permalink
Merge branch 'develop' of github.com:ecmwf/climetlab into develop
Browse files Browse the repository at this point in the history
  • Loading branch information
b8raoult committed Feb 25, 2024
2 parents 235d104 + 9a5e605 commit 3572fb6
Show file tree
Hide file tree
Showing 4 changed files with 11 additions and 18 deletions.
6 changes: 3 additions & 3 deletions climetlab/readers/grib/output.py
Original file line number Diff line number Diff line change
Expand Up @@ -199,9 +199,9 @@ def update_metadata(self, handle, metadata, compulsary):
if "number" in metadata:
compulsary += ("numberOfForecastsInEnsemble",)
productDefinitionTemplateNumber = {"tp": 11}
metadata[
"productDefinitionTemplateNumber"
] = productDefinitionTemplateNumber.get(handle.get("shortName"), 1)
metadata["productDefinitionTemplateNumber"] = (
productDefinitionTemplateNumber.get(handle.get("shortName"), 1)
)

if metadata.get("type") in ("pf", "cf"):
metadata.setdefault("typeOfGeneratingProcess", 4)
Expand Down
19 changes: 6 additions & 13 deletions climetlab/readers/netcdf/fieldset.py
Original file line number Diff line number Diff line change
Expand Up @@ -181,6 +181,12 @@ class NetCDFFieldSetFromFileOrURL(NetCDFFieldSet):
def __init__(self, path_or_url):
self.path_or_url = path_or_url

@cached_property
def xr_dataset(self):
import xarray as xr

return xr.open_dataset(self.path_or_url)


class NetCDFFieldSetFromFile(NetCDFFieldSetFromFileOrURL):
def __init__(self, path):
Expand All @@ -202,12 +208,6 @@ def __init__(self, url):
def __repr__(self):
return "NetCDFFieldSetFromURL(%s)" % (self.path_or_url,)

@cached_property
def xr_dataset(self):
import xarray as xr

return xr.open_dataset(self.path_or_url)


class NetCDFMaskFieldSet(NetCDFFieldSet, MaskIndex):
def __init__(self, *args, **kwargs):
Expand Down Expand Up @@ -239,13 +239,6 @@ def fields(self):
result.extend(s.fields)
return result

# @cached_property
# def dataset(self):
# return self.to_xarray(combine="by_coords")

# def __iter__(self):
# return MultiIndex.__iter__(self)

def __len__(self):
return MultiIndex.__len__(self)

Expand Down
2 changes: 1 addition & 1 deletion climetlab/version
Original file line number Diff line number Diff line change
@@ -1 +1 @@
0.20.15
0.21.0
2 changes: 1 addition & 1 deletion tests/readers/test_netcdf_reader.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ def test_netcdf():
def test_dummy_netcdf_reader_1():
s = load_source("file", climetlab_file("docs/examples/test.nc"))
r = s._reader
assert str(r).startswith("NetCDFReader"), r
assert str(r).startswith("NetCDFFieldSetFromFile"), r
assert len(r) == 2
assert isinstance(r[1], NetCDFField), r

Expand Down

0 comments on commit 3572fb6

Please sign in to comment.