| 24 | |
| 25 | |
| 26 | class Tuple: |
| 27 | __dask_scheduler__ = staticmethod(dask.threaded.get) |
| 28 | __dask_optimize__ = None |
| 29 | |
| 30 | def __init__(self, dsk, keys): |
| 31 | self._dask = dsk |
| 32 | self._keys = keys |
| 33 | |
| 34 | def __dask_tokenize__(self): |
| 35 | return self._keys |
| 36 | |
| 37 | def __dask_graph__(self): |
| 38 | return self._dask |
| 39 | |
| 40 | def __dask_keys__(self): |
| 41 | return self._keys |
| 42 | |
| 43 | def __dask_postcompute__(self): |
| 44 | return tuple, () |
| 45 | |
| 46 | |
| 47 | @pytest.mark.filterwarnings("ignore:The dask.delayed:UserWarning") |
no outgoing calls