to_delayed

Catalog.to_delayed(optimize_graph: bool = True) → list[Delayed]

Get a list of Dask Delayed objects for each partition in the dataset

Used for more advanced custom operations, but to use again with LSDB, the delayed objects must be converted to a Dask DataFrame and used with extra metadata to construct an LSDB Dataset.

Parameters:

optimize_graph: bool, default True

Whether to optimize the Dask task graph.

Returns:

list[Delayed]

A list of Dask delayed partitions.