Including Keyword Arguments (kwargs) In Custom Dask Graphs

Am building a custom graph for one operation with Dask. Am familiar with how to pass arguments to a function in Dask graph and have read up on the docs. However still seem to be mi

Solution 1:

A common workaround is to use the apply function

from dask.compatibility import apply
task = (apply, func, args, kwargs)  # func(*args, **kwargs)

Solution 2:

The answer by @MRocklin should be edited to conform to newer dask versions:

from dask.utils import apply
task = (apply, func, args, kwargs)  # func(*args, **kwargs)