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