dask.bag.Bag.to_delayed

Contents

dask.bag.Bag.to_delayed#

Bag.to_delayed(optimize_graph=True)[source]#

Convert into a list of dask.delayed objects, one per partition.

Parameters:
optimize_graphbool, optional

If True [default], the graph is optimized before converting into dask.delayed objects.