(self)
| 1129 | return self._dask_finalize, (self.name, func) + args |
| 1130 | |
| 1131 | def __dask_postpersist__(self): |
| 1132 | func, args = self._to_temp_dataset().__dask_postpersist__() |
| 1133 | return self._dask_finalize, (self.name, func) + args |
| 1134 | |
| 1135 | @classmethod |
| 1136 | def _dask_finalize(cls, results, name, func, *args, **kwargs) -> Self: |
nothing calls this directly
no test coverage detected