get

A get is used to execute a task graph. This is provided by different schedulers.

  1. dask.threaded.get
  2. dask.multiprocessing.get
  3. dask.distributed.Client.get
dsk = {
       "x": 1,
       "y": (operator.add, 'x', 1)
}
dask.threaded.get(dsk, 'y')
dask.threaded.get(dsk, 'x')

References

  1. https://docs.dask.org/en/stable/scheduler-overview.html