(self)
| 1061 | |
| 1062 | @functools.cached_property |
| 1063 | def _optimized_dsk(self) -> HighLevelGraph: |
| 1064 | from dask.highlevelgraph import HighLevelGraph |
| 1065 | |
| 1066 | optimizer = self.low_level_optimizer |
| 1067 | keys = self.__dask_keys__() |
| 1068 | dsk = self.hlg |
| 1069 | if (optimizer := self.low_level_optimizer) is not None: |
| 1070 | dsk = optimizer(dsk, keys) |
| 1071 | return HighLevelGraph.merge(dsk) |
| 1072 | |
| 1073 | @property |
| 1074 | def deterministic_token(self): |
nothing calls this directly
no test coverage detected