dask_awkward.from_delayed

dask_awkward.from_delayed(source, meta=None, behavior=None, divisions=None, prefix='from-delayed', attrs=None)

Create an Array collection from a set of Delayed objects.

Parameters:

• source (list[dask.delayed.Delayed] | dask.delayed.Delayed) – List of Delayed objects (or a single object). Each Delayed object represents a single partition in the resulting awkward array.

• meta (ak.Array, optional) – Metadata (typetracer array) if known, if None the first partition (first element of the list of Delayed objects) will be computed to determine the metadata.

• behavior (dict, optional) – Custom ak.behavior for the output array.

• divisions (tuple[int | None, ...], optional) – Partition boundaries (if known).

• prefix (str) – Prefix for the keys in the task graph.

• attrs (mapping, optional) – Custom attributes for the output array.

Returns:

Resulting Array collection.

Return type:

Array