dask_awkward.to_delayed

dask_awkward.to_delayed(array, optimize_graph=True)

Convert Arrray the collection to a list of Delayed objects.

One dask.delayed.Delayed object per partition.

Parameters:

• optimize_graph (bool) – If True the task graph associated with the collection will be optimized before conversion to the list of Delayed objects.

• array (Array)

Returns:

List of delayed objects (one per partition).

Return type:

list[dask.delayed.Delayed]