Convert into a list of ``dask.delayed`` objects, one per partition. Parameters ---------- optimize_graph : bool, optional If True [default], the graph is optimized before converting into ``dask.delayed`` objects. Examples --------
(self, optimize_graph=True)
| 2497 | return to_hdf(self, path_or_buf, key, mode, append, **kwargs) |
| 2498 | |
| 2499 | def to_delayed(self, optimize_graph=True): |
| 2500 | """Convert into a list of ``dask.delayed`` objects, one per partition. |
| 2501 | |
| 2502 | Parameters |
| 2503 | ---------- |
| 2504 | optimize_graph : bool, optional |
| 2505 | If True [default], the graph is optimized before converting into |
| 2506 | ``dask.delayed`` objects. |
| 2507 | |
| 2508 | Examples |
| 2509 | -------- |
| 2510 | >>> partitions = df.to_delayed() # doctest: +SKIP |
| 2511 | |
| 2512 | See Also |
| 2513 | -------- |
| 2514 | dask_expr.from_delayed |
| 2515 | """ |
| 2516 | from dask.highlevelgraph import HighLevelGraph |
| 2517 | |
| 2518 | if optimize_graph: |
| 2519 | frame = self.optimize() |
| 2520 | else: |
| 2521 | frame = self |
| 2522 | keys = frame.__dask_keys__() |
| 2523 | graph = frame.__dask_graph__() |
| 2524 | layer = f"delayed-{frame._name}" |
| 2525 | graph = HighLevelGraph.from_collections(layer, graph, dependencies=()) |
| 2526 | return [Delayed(k, graph, layer=layer) for k in keys] |
| 2527 | |
| 2528 | def to_backend(self, backend: str | None = None, **kwargs): |
| 2529 | """Move to a new DataFrame backend |
nothing calls this directly
no test coverage detected