Open mrocklin opened 9 months ago
(my apologies if this has been mentioned / done in some other way and I'm out of date)
This is covered by the scheduler integration basically
I'm curious to learn more. Is there a PR I should be aware of? How does this work with the local scheduler?
No new PR other than https://github.com/dask-contrib/dask-expr/pull/294 where I added a Tuple
as you suggested. I still have to update the dask/dask and dask/distributed PRs accordingly
this likely requires to build this tuple in collections_to_dsk
but I don't expect much more work for this
We probably need to modify
dask.base
to call some dask-exproptimize
function. We probably also want to call this on everything we're computing all at once.