Optimize a dask from a dask Bag.
(dsk, keys, fuse_keys=None, **kwargs)
| 160 | |
| 161 | |
| 162 | def optimize(dsk, keys, fuse_keys=None, **kwargs): |
| 163 | """Optimize a dask from a dask Bag.""" |
| 164 | dsk = convert_legacy_graph(dsk) |
| 165 | keys = list(flatten(keys)) |
| 166 | dsk2 = cull(dsk, keys) |
| 167 | dsk3 = fuse_linear_task_spec(dsk2, keys + (fuse_keys or [])) |
| 168 | dsk4 = lazify(dsk3) |
| 169 | return dsk4 |
| 170 | |
| 171 | |
| 172 | def _to_textfiles_chunk(data, lazy_file, last_endline): |