(collection)
| 52 | |
| 53 | |
| 54 | def finalize(collection): |
| 55 | assert is_dask_collection(collection) |
| 56 | |
| 57 | name = "finalize-" + tokenize(collection) |
| 58 | expr = collections_to_expr(collection).finalize_compute() |
| 59 | return Delayed(name, expr) |
| 60 | |
| 61 | |
| 62 | def _convert_dask_keys(keys: NestedKeys) -> List: |
nothing calls this directly
no test coverage detected
searching dependent graphs…