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