dask_awkward.to_delayed

dask_awkward.to_delayed

dask_awkward.to_delayed(array, optimize_graph=True)[source]

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]