(self, results: Iterable[Variable])
| 697 | return self._dask_postpersist, () |
| 698 | |
| 699 | def _dask_postcompute(self, results: Iterable[Variable]) -> Self: |
| 700 | import dask |
| 701 | |
| 702 | variables = {} |
| 703 | results_iter = iter(results) |
| 704 | |
| 705 | for k, v in self._variables.items(): |
| 706 | if dask.is_dask_collection(v): |
| 707 | rebuild, args = v.__dask_postcompute__() |
| 708 | v = rebuild(next(results_iter), *args) |
| 709 | variables[k] = v |
| 710 | |
| 711 | return type(self)._construct_direct( |
| 712 | variables, |
| 713 | self._coord_names, |
| 714 | self._dims, |
| 715 | self._attrs, |
| 716 | self._indexes, |
| 717 | self._encoding, |
| 718 | self._close, |
| 719 | ) |
| 720 | |
| 721 | def _dask_postpersist( |
| 722 | self, dsk: Mapping, *, rename: Mapping[str, str] | None = None |
nothing calls this directly
no test coverage detected