Use the new HLG pack/unpack API in Dask#4489
Conversation
349e26e to
2550bee
Compare
jrbourbeau
left a comment
There was a problem hiding this comment.
Thanks for your work here @madsbk! I pushed an update to run CI against dask/dask#7179 to ensure that the distributed test suite passes too.
We'll also want to update the minimum supported version of dask to make sure HighLevelGraphs have the new __dask_distributed_(un)pack__ API. Historically what we've done in this case is update distributeds requirements.txt to point to the master branch of dask and add a TODO comment to update to the latest dask release prior to releasing distributed
d5718f9 to
b6bb295
Compare
|
Thanks @jrbourbeau, both PRs should work now. I have added some tests of the issue in Dask and renamed Some of the CI runs fails in |
Yeah you're correct, that failure is be related to pointing CI to your branch. Since our versioning system, This is okay as it's only an artifact of pointing to a fork of |
jrbourbeau
left a comment
There was a problem hiding this comment.
Thanks @madsbk! This LGTM. See my comment at dask/dask#7179 (review) about waiting a day to merge this PR
This PR makes Distributed use the new high level graph pack/unpack API in Dask: dask/dask#7179
black distributed/flake8 distributed