dask_awkward.to_delayed

dask_awkward.to_delayed¶

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

Convert 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.
Returns: List of delayed objects (one per partition).
Return type: list[dask.delayed.Delayed]

dask_awkward.to_dask_array

dask_awkward.to_parquet