xarray_beam.consolidate_variables¶

xarray_beam.consolidate_variables(inputs, merge_kwargs=None)[source]¶

Consolidate chunks across distinct variables into (Key, Dataset) pairs.

Parameters:

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

Return type:

Iterator[tuple[Key, Dataset]]