fix(ecmwf): Read in lat and lon in full chunks

devsjc · devsjc · commit 46b4da20e602 · 2025-05-19T16:57:13.000+01:00
diff --git a/src/nwp_consumer/internal/repositories/raw_repositories/ecmwf_mars.py b/src/nwp_consumer/internal/repositories/raw_repositories/ecmwf_mars.py
@@ -321,7 +321,7 @@ def _convert(path: pathlib.Path) -> ResultE[list[xr.DataArray]]:
         try:
             dss: list[xr.Dataset] = cfgrib.open_datasets(
                 path=path.as_posix(),
-                chunks={"time": 1, "step": -1, "longitude": "auto", "latitude": "auto"},
+                chunks={"time": 1, "step": -1, "longitude": -1, "latitude": -1},
                 backend_kwargs={"indexpath": ""},
             )
         except Exception as e:

Original file line number	Diff line number	Diff line change
`@@ -321,7 +321,7 @@ def _convert(path: pathlib.Path) -> ResultE[list[xr.DataArray]]:`
`321`	`321`	`try:`
`322`	`322`	`dss: list[xr.Dataset] = cfgrib.open_datasets(`
`323`	`323`	`path=path.as_posix(),`
`324`		`- chunks={"time": 1, "step": -1, "longitude": "auto", "latitude": "auto"},`
	`324`	`+ chunks={"time": 1, "step": -1, "longitude": -1, "latitude": -1},`
`325`	`325`	`backend_kwargs={"indexpath": ""},`
`326`	`326`	`)`
`327`	`327`	`except Exception as e:`