Skip to content

Commit c5b439a

Browse files
committed
make chunk size of lat and lon 1
1 parent 68651b3 commit c5b439a

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/nwp_consumer/internal/repositories/raw_repositories/ecmwf_realtime.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -282,6 +282,10 @@ def _convert(path: pathlib.Path) -> ResultE[list[xr.DataArray]]:
282282
.sortby(variables=["step", "variable", "longitude"])
283283
.sortby(variables="latitude", ascending=False)
284284
)
285+
286+
# change lat and lon chunk size to 1
287+
da = da.chunk({"latitude": 1, "longitude": 1})
288+
285289
except Exception as e:
286290
return Failure(ValueError(
287291
f"Error processing dataset {i} from '{path}' to DataArray: {e}",

0 commit comments

Comments
 (0)