xarray_beam.consolidate_chunks¶

xarray_beam.consolidate_chunks(inputs, combine_kwargs=None)[source]¶

Consolidate chunks across offsets into (Key, Dataset) pairs.

Parameters:

inputs (Iterable[tuple[Key, Dataset]])
combine_kwargs (Mapping[str, Any] | None)

Return type:

Iterable[tuple[Key, Dataset]]