Changes
- Remove redundant methods in P2PBarrierTask @fjetter (#8924)
- fix skipif condition for test_tell_workers_when_peers_have_left @fjetter (#8929)
- Ensure ConnectionPool closes even if network stack swallows cancellation @fjetter (#8928)
- Fix flaky test_server_comms_mark_active_handlers @fjetter (#8927)
- Make assumption in P2P's barrier mechanism explicit @hendrikmakait (#8926)
- Adjust timeouts in jupyter cli test @fjetter (#8925)
- Add
stimulus_id
toSchedulerPlugin.update_graph
hook @hendrikmakait (#8923) - Reduce P2P transfer task overhead @hendrikmakait (#8912)
- Disable profiler on python 3.11 @fjetter (#8916)
- Fix test_restarting_does_not_deadlock @fjetter (#8849)
- Adjust popen timeouts for testing @fjetter (#8848)
- Add retry to shuffle broadcast @fjetter (#8900)
- Fix test_shuffle_with_array_conversion @fjetter (#8909)
- Refactor some tests @fjetter (#8908)
- Reflect graduation of
dask-expr
fromdask-contrib
todask
@hendrikmakait (#8911) - Skip test_tell_workers_when_peers_have_left on py3.10 @fjetter (#8910)
- Internal cleanup of P2P code @hendrikmakait (#8907)
- Use Task class instead of tuple @fjetter (#8797)
- Increase connect timeout for test_tell_workers_when_peers_have_left @fjetter (#8906)
- Remove dispatching in TaskCollection @fjetter (#8903)
- Deduplicate scheduler requests in P2P @hendrikmakait (#8899)
- Add configurations for rootish taskgroup threshold @phofl (#8898)
See the Changelog for more information.