(self)
| 1400 | return (self.name,) |
| 1401 | |
| 1402 | def __dask_keys__(self) -> NestedKeys: |
| 1403 | if self._cached_keys is not None: |
| 1404 | return self._cached_keys |
| 1405 | |
| 1406 | name, chunks, numblocks = self.name, self.chunks, self.numblocks |
| 1407 | |
| 1408 | def keys(*args): |
| 1409 | if not chunks: |
| 1410 | return [(name,)] |
| 1411 | ind = len(args) |
| 1412 | if ind + 1 == len(numblocks): |
| 1413 | result = [(name,) + args + (i,) for i in range(numblocks[ind])] |
| 1414 | else: |
| 1415 | result = [keys(*(args + (i,))) for i in range(numblocks[ind])] |
| 1416 | return result |
| 1417 | |
| 1418 | self._cached_keys = result = keys() |
| 1419 | return result |
| 1420 | |
| 1421 | def __dask_tokenize__(self): |
| 1422 | return self.name |
no outgoing calls
no test coverage detected