(self, key)
| 994 | self._cache.clear() |
| 995 | |
| 996 | def __getitem__(self, key): |
| 997 | if (val := self._cache.get(key)) is not None: |
| 998 | return val |
| 999 | else: |
| 1000 | v = self.dsk[key] |
| 1001 | try: |
| 1002 | deps = v.dependencies |
| 1003 | except AttributeError: |
| 1004 | from dask.core import get_dependencies |
| 1005 | |
| 1006 | deps = get_dependencies(self.dsk, task=v) |
| 1007 | |
| 1008 | if self._removed: |
| 1009 | # deps is a frozenset but for good measure, let's not use -= since |
| 1010 | # that _may_ perform an inplace mutation |
| 1011 | deps = deps - self._removed |
| 1012 | self._cache[key] = deps |
| 1013 | return deps |
| 1014 | |
| 1015 | def __iter__(self): |
| 1016 | return iter(self.dsk) |
nothing calls this directly
no test coverage detected