(self)
| 1049 | return dict(annotations_by_type) |
| 1050 | |
| 1051 | def __dask_keys__(self): |
| 1052 | if (keys := self.operand("output_keys")) is not None: |
| 1053 | return keys |
| 1054 | dsk = self.hlg |
| 1055 | # Note: This will materialize |
| 1056 | dependencies = dsk.get_all_dependencies() |
| 1057 | leafs = set(dependencies) |
| 1058 | for val in dependencies.values(): |
| 1059 | leafs -= val |
| 1060 | self.output_keys = list(leafs) |
| 1061 | return self.output_keys |
| 1062 | |
| 1063 | @functools.cached_property |
| 1064 | def _optimized_dsk(self) -> HighLevelGraph: |
no test coverage detected