get
A get
is used to execute a task graph. This is provided by different schedulers.
dask.threaded.get
dask.multiprocessing.get
dask.distributed.Client.get
dsk = {
"x": 1,
"y": (operator.add, 'x', 1)
}
dask.threaded.get(dsk, 'y')
dask.threaded.get(dsk, 'x')