Function call_function

dask/delayed.py:806–826

(func, func_token, args, kwargs, pure=None, nout=None)

def call_function(func, func_token, args, kwargs, pure=None, nout=None):
    dask_key_name = kwargs.pop("dask_key_name", None)
    pure = kwargs.pop("pure", pure)

    if dask_key_name is None:
        name = f"{funcname(func)}-{tokenize(func_token, *args, pure=pure, **kwargs)}"
    else:
        name = dask_key_name

    args2, collections = unzip(map(unpack_collections, args), 2)
    collections = list(concat(collections))

    dask_kwargs, collections2 = unpack_collections(kwargs)
    collections.extend(collections2)
    task = Task(name, func, *args2, **dask_kwargs)

    graph = HighLevelGraph.from_collections(
        name, {name: task}, dependencies=collections
    )
    nout = nout if nout is not None else None
    return Delayed(name, graph, length=nout)


class DelayedLeaf(Delayed):