- Update to 2024.6.2:
* profile._f_lineno: handle next_line being None in Python 3.13
* Cache global query-planning config
* Python 3.13 fixes
* Fix test_map_freq_to_period_start for pandas=3
* Tokenizing memmap arrays will now avoid materializing the array into
memory.
* Fix test_dt_accessor with query planning disabled
* Remove deprecated dask.compatibility module
* Ensure compatibility for xarray.NamedArray
* Avoid rounding error in
test_prometheus_collect_count_total_by_cost_multipliers
* Log key collision count in update_graph log event
* Rename safe to expected in Scheduler.remove_worker
* Eagerly update aggregate statistics for TaskPrefix instead of
calculating them on-demand
* Improve graph submission time for P2P rechunking by avoiding unpack
recursion into indices
* Add safe keyword to remove-worker event
* Improved errors and reduced logging for P2P RPC calls
* Adjust P2P tests for dask-expr
* Iterate over copy of Server.digests_total_since_heartbeat to avoid
RuntimeError
* Add Prometheus gauge for task groups
* Fix too strict assertion in shuffle code for pandas subclasses
* Reduce noise from erring tasks that are not supposed to be running
OBS-URL: https://build.opensuse.org/request/show/1186064
OBS-URL: https://build.opensuse.org/package/show/openSUSE:Factory/python-distributed?expand=0&rev=81
* profile._f_lineno: handle next_line being None in Python 3.13
* Cache global query-planning config
* Python 3.13 fixes
* Fix test_map_freq_to_period_start for pandas=3
* Tokenizing memmap arrays will now avoid materializing the array into
memory.
* Fix test_dt_accessor with query planning disabled
* Remove deprecated dask.compatibility module
* Ensure compatibility for xarray.NamedArray
* Avoid rounding error in
test_prometheus_collect_count_total_by_cost_multipliers
* Log key collision count in update_graph log event
* Rename safe to expected in Scheduler.remove_worker
* Eagerly update aggregate statistics for TaskPrefix instead of
calculating them on-demand
* Improve graph submission time for P2P rechunking by avoiding unpack
recursion into indices
* Add safe keyword to remove-worker event
* Improved errors and reduced logging for P2P RPC calls
* Adjust P2P tests for dask-expr
* Iterate over copy of Server.digests_total_since_heartbeat to avoid
RuntimeError
* Add Prometheus gauge for task groups
* Fix too strict assertion in shuffle code for pandas subclasses
* Reduce noise from erring tasks that are not supposed to be running
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python:numeric/python-distributed?expand=0&rev=169
* see corresponding dask update:
* https://docs.dask.org/en/stable/changelog.html#v2023-12-0
* Bokeh 3.3.0 compatibility
- Update to version 2022.11.1
* Automatically mark all WorkerState tests (:pr:`6706`) crusaderky
- Update to 2022.6.1
- add distributed-fix-python310.patch to fix build with python 3.10
- Update to version 2021.9.1
* Fix add_plugin warnings
* Add list around iterator in handle_missing_dep
* Jupyter-client 7 compatiblity
* Add standalone dashboard page for GPU usage (GH#4556) Jacob
* Handle stream is None case in TCP comm finalizer (GH#4631)
* Include LIST_PICKLE in NumPy array serialization (GH#4632)
* Rename annotation plugin in test_highlevelgraph.py (GH#4618)
* Skip NumPy and pandas tests if not importable (GH#4563) Ben
* Remove utils.shutting_down in favor of sys.is_finalizing
* Introduce events log length config option (GH#4615) Fabian
* Upstream config serialization and inheritance (GH#4372) Jacob
* Add check to scheduler creation in SpecCluster (GH#4605) Jacob
* Make length of events deque configurable (GH#4604) Fabian
* Add explicit fetch state to worker TaskState (GH#4470) Gil
* pickle_loads(): Handle empty memoryview (GH#4595) Mads R. B.
* Switch documentation builds for PRs to readthedocs (GH#4599)
* If SpecCluster fails to start attempt to gracefully close out
* IPython magics: remove deprecated ioloop workarounds (GH#4530)
* Add GitHub actions workflow to cancel duplicate builds
* Remove outdated macOS build badge from README (GH#4576) James
* Change default branch from master to main (GH#4495) Julia
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python:numeric/python-distributed?expand=0&rev=149
- Update to 2023.11.0
- add distributed-ignore-rerun.patch to ignore pytest runners during
test code introspection
* Zero-copy P2P Array Rechunking
* Deprecating PyArrow <14.0.1
* Improved PyArrow filesystem for Parquet
* Improve Type Reconciliation in P2P Shuffling
* official support for Python 3.12
* Reduced memory pressure for multi array reductions
* improved P2P shuffling robustness
* Reduced scheduler CPU load for large graphs (forwarded request 1127182 from mimi_vx)
OBS-URL: https://build.opensuse.org/request/show/1127185
OBS-URL: https://build.opensuse.org/package/show/openSUSE:Factory/python-distributed?expand=0&rev=72
- Ratchet up bokeh to >= 3.1, since upstream supports it.
- Also BuildRequire sparse for Python 3.11.
- Update to 2023.5.1
* This release drops support for Python 3.8
## Enhancements
* Exclude IPython code from computations (GH#7788) Miles
* Drop Python 3.8 support (GH#7840) Thomas Grainger
* Add storage_options to performance_report (GH#7636) ypogorelova
* Don’t warn about mismatched msgpack (GH#7839) Irina Truong
* Clean up sys.path on Server shutdown (GH#7838) James Bourbeau
* Dashboard: Fine Performance Metrics (GH#7725) Miles
## Bug Fixes
* Properly handle unknown chunk sizes in P2P rechunking (GH#7856)
Hendrik Makait
* Minimal change to work around (GH#7726) / support for UCX
(GH#7851) Benjamin Zaitlen
* Don’t end computations until cluster is truly idle (GH#7790)
crusaderky
- Release 2023.5.0
## Enhancements
* Client.upload_file send to both Workers and Scheduler and
rename scratch directory (GH#7802) Miles
* Allow dashboard to be used with bokeh prereleases (GH#7814)
James Bourbeau
## Bug Fixes
* Ensure log_event of non-msgpack serializable object do not kill
servers (GH#7472) Florian Jetter
* Fix test_nanny.py duplicated pytestmark definitions (GH#7819)
Thomas Grainger
OBS-URL: https://build.opensuse.org/request/show/1090796
OBS-URL: https://build.opensuse.org/package/show/openSUSE:Factory/python-distributed?expand=0&rev=70
- Update to 2023.5.1
* This release drops support for Python 3.8
## Enhancements
* Exclude IPython code from computations (GH#7788) Miles
* Drop Python 3.8 support (GH#7840) Thomas Grainger
* Add storage_options to performance_report (GH#7636) ypogorelova
* Don’t warn about mismatched msgpack (GH#7839) Irina Truong
* Clean up sys.path on Server shutdown (GH#7838) James Bourbeau
* Dashboard: Fine Performance Metrics (GH#7725) Miles
## Bug Fixes
* Properly handle unknown chunk sizes in P2P rechunking (GH#7856)
Hendrik Makait
* Minimal change to work around (GH#7726) / support for UCX
(GH#7851) Benjamin Zaitlen
* Don’t end computations until cluster is truly idle (GH#7790)
crusaderky
- Release 2023.5.0
## Enhancements
* Client.upload_file send to both Workers and Scheduler and
rename scratch directory (GH#7802) Miles
* Allow dashboard to be used with bokeh prereleases (GH#7814)
James Bourbeau
## Bug Fixes
* Ensure log_event of non-msgpack serializable object do not kill
servers (GH#7472) Florian Jetter
* Fix test_nanny.py duplicated pytestmark definitions (GH#7819)
Thomas Grainger
* Fix flaky
test_dask_worker.py::test_single_executable_deprecated
(GH#7817) Thomas Grainger
OBS-URL: https://build.opensuse.org/request/show/1090160
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python:numeric/python-distributed?expand=0&rev=142
- Update to 2023.3.2
## Enhancements
* Enhanced thread-safety in zict.File (GH#7691) crusaderky
* Future deserialization without available client (GH#7580)
Florian Jetter
* Support adjusting GIL monitoring interval (GH#7650) Miles
* Gracefully stop GIL monitoring if running (GH#7652) Miles
* Fine performance metrics for execute, gather_dep, etc.
(GH#7586) crusaderky
* Add GIL metric to dashboard (GH#7646) Miles
* Expose scheduler idle via RPC and HTTP API (GH#7642) Jacob
Tomlinson
* Add full dashboard link in scheduler logs (GH#7631) Miles
## Bug Fixes
* Tell workers when their peers have left (so they don’t hang
fetching data from them) (GH#7574) Thomas Grainger
* Fix regression in dashboard after (GH#7586) (GH#7683)
crusaderky
* Fix OverflowError in Cluster._sync_cluster_info() (GH#7648)
Hendrik Makait
* Ensure that serialized data is measured correctly (GH#7593)
Florian Jetter
## Maintenance
* Avoid bool object has no attribute close in @gen_cluster
(GH#7657) Thomas Grainger
* Fix failing test_server_close_stops_gil_monitoring (GH#7659)
James Bourbeau
* Remove weakref finalizer for Offload Executor (GH#7644) Florian
Jetter
- Enable python311 build and test: numba not a strict requirement
OBS-URL: https://build.opensuse.org/request/show/1074755
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python:numeric/python-distributed?expand=0&rev=138
Has to go together with sr#1071019!
- Skip more flaky tests
- Update to 2023.3.1
## Enhancements
* Add Jupyter link to dashboard menu if --jupyter flag is set
(GH#7638) Jacob Tomlinson
* Bump minimum click version from 7.0 to 8.0 (GH#7637) Miles
* Extend dask metapackage dependencies (GH#7630) James Bourbeau
* Further improvements to Client.restart_workers (GH#7620) Miles
* P2P offload get_output_partition (GH#7587) Florian Jetter
* Initial integration of GIL contention metric (GH#7624) Miles
* Add dashboard documentation links (GH#7610) Miles
* Rename shuffle/rechunk config option/kwarg to method (GH#7623)
Hendrik Makait
* Return results in restart_workers (GH#7606) Miles
* Ensure client key cancellation uses ordered messages (GH#7583)
Florian Jetter
## Bug Fixes
* Fix undefined async_wait_for -> async_poll_for (GH#7627) Miles
* Don’t send client heartbeat without a scheduler_comm (GH#7612)
James Bourbeau
* Do not unspill on free-keys (GH#7607) crusaderky
## Documentation
* Add notes to Client.submit, Client.map, and Client.scatter with
the description of the current task graph resolution algorithm
limitations (GH#7588) Eugene Druzhynin
## Maintenance
* Use range with pickle protocol versions (GH#7635) jakirkham
* Share thread pool among P2P shuffle runs (GH#7621) Hendrik
Makait
* Replace psutil suspend with BlockedGatherDep in
test_failing_worker_with_additional_replicas_on_cluster
(GH#7633) Thomas Grainger
* Ignore pkg_resources DeprecationWarning for mindeps (GH#7626)
Miles
* Implement wait_for using asyncio.timeout() on 3.11 (GH#7571)
Thomas Grainger
* Use tmp_path fixture instead of outdated tmpdir fixture
(GH#7582) ypogorelova
* Only one crick callback (GH#7614) crusaderky
* Add mindeps + numpy job to tests CI (GH#7609) Miles
* Do not xfail whole tests due to (GH#6705) (GH#7611) crusaderky
OBS-URL: https://build.opensuse.org/request/show/1071516
OBS-URL: https://build.opensuse.org/package/show/openSUSE:Factory/python-distributed?expand=0&rev=67
- Skip more flaky tests
- Update to 2023.3.1
## Enhancements
* Add Jupyter link to dashboard menu if --jupyter flag is set
(GH#7638) Jacob Tomlinson
* Bump minimum click version from 7.0 to 8.0 (GH#7637) Miles
* Extend dask metapackage dependencies (GH#7630) James Bourbeau
* Further improvements to Client.restart_workers (GH#7620) Miles
* P2P offload get_output_partition (GH#7587) Florian Jetter
* Initial integration of GIL contention metric (GH#7624) Miles
* Add dashboard documentation links (GH#7610) Miles
* Rename shuffle/rechunk config option/kwarg to method (GH#7623)
Hendrik Makait
* Return results in restart_workers (GH#7606) Miles
* Ensure client key cancellation uses ordered messages (GH#7583)
Florian Jetter
## Bug Fixes
* Fix undefined async_wait_for -> async_poll_for (GH#7627) Miles
* Don’t send client heartbeat without a scheduler_comm (GH#7612)
James Bourbeau
* Do not unspill on free-keys (GH#7607) crusaderky
## Documentation
* Add notes to Client.submit, Client.map, and Client.scatter with
the description of the current task graph resolution algorithm
limitations (GH#7588) Eugene Druzhynin
## Maintenance
* Use range with pickle protocol versions (GH#7635) jakirkham
* Share thread pool among P2P shuffle runs (GH#7621) Hendrik
Makait
OBS-URL: https://build.opensuse.org/request/show/1071308
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python:numeric/python-distributed?expand=0&rev=136
- Update to 2023.1.1
## Enhancements
* P2P shuffle deduplicates data and can be run several times
(GH#7486) Hendrik Makait
* Reverse order of get_logs() and get_worker_logs() (GH#7475)
Nicholas R. Knezek
* Add prometheus metric for time and memory used per task prefix
(GH#7406) Thomas Grainger
* Additive worker counts in Prometheus (GH#7468) crusaderky
* Add help tool for taskstream (GH#7478) Florian Jetter
## Bug Fixes
* Do not allow for a worker to reject a drop replica request
(GH#7490) Hendrik Makait
* Fix un/packing for namedtuples with custom constructors
(GH#7465) antonymayi
* Documentation
* Remove timeout= from docstring example for worker_client
(GH#7497) Florian Jetter
## Maintenance
* Ignore get_default_shuffle_algorithm linting issue (GH#7506)
Florian Jetter
* Remove set_config when using default client (GH#7482) Florian
Jetter
* Update gpuCI RAPIDS_VER to 23.04 (GH#7501)
* Fix test_balance_expensive_tasks and improve helper functions
in test_steal.py (GH#7253) Hendrik Makait
* Sign every compute task with run ID to correlate response
(GH#7463) Hendrik Makait
- Release 2023.1.0
## New Features
* Add local SubprocessCluster that runs workers in separate
processes (GH#7431) Hendrik Makait
## Enhancements
* Ensure client session is quiet after cluster.close() or
client.shutdown() (GH#7429) James Bourbeau
* Set lifetime-stagger default value to None (GH#7445)
bstadlbauer
* Memory thresholds should never be exactly 0.0 (GH#7458) Stuart
Berg
* Remove the Incorrect-Sizeof-Warning (GH#7450) Mads R. B.
Kristensen
* Log exceptions in P2P shuffle tasks (GH#7442) Hendrik Makait
* Add support for packing namedtuple and add test for future
resolution in submit (GH#7292) Andrew
* Avoid deep copy on lz4 decompression (GH#7437) crusaderky
* Avoid deep copy of numpy buffers on unspill (GH#7435)
crusaderky
* Don’t error when clicking on empty task stream plot (GH#7432)
James Bourbeau
* Do not count spilled memory when comparing vs. process memory
(GH#7430) crusaderky
* Stop Client periodic callbacks during shutdown() (GH#7428)
James Bourbeau
* Add dask spec CLI (GH#7427) Matthew Rocklin
* Create new zstd (de)compressor for each compression call
(GH#7404) Dylan Wragge
* Rename managed_in_memory etc. to match GUI (GH#7418) crusaderky
* Warn users when sizeof() returns inflated output (GH#7419)
crusaderky
## Bug Fixes
* Ensure dicts are properly recognized as msgpack serializable
(GH#7473) Florian Jetter
* Reset state of ShuffleSchedulerExtension on restart (GH#7446)
Hendrik Makait
* Reject non-string column names in P2P shuffle (GH#7447) Hendrik
Makait
* Avoid int32 in dashboard (GH#7443) Matthew Rocklin
* Fix P2PShuffle serialization for categorical data (GH#7410)
Hendrik Makait
* WorkerPorcess blocks on kill if still starting (GH#7424)
Matthew Rocklin
## Documentation
* Move Prometheus docs from dask/dask (GH#7405) crusaderky
## Maintenance
* Various cleanups in semaphore (GH#5885) Florian Jetter
* test_rlimit fails on MacOSX (GH#7457) crusaderky
* Bump actions/checkout from 3.2.0 to 3.3.0 (GH#7464)
* Remove conditional imports of psutil (GH#7462) crusaderky
* Drop support for zict < 2.1.0 (GH#7456) crusaderky
* Fix flaky test_digests (GH#7454) crusaderky
* Add minimum dependency testing to CI (GH#7285) Charles
Blackmon-Luca
* Avoid overflow in statitics.mean (GH#7426) Matthew Rocklin
* Ignore numpy bool8 deprecation (GH#7423) Matthew Rocklin
* Add missing skips for pyarrow (GH#7416) Elliott Sales de
Andrade
* Be more permissive about expected ciphers in tests (GH#7417)
Elliott Sales de Andrade
* Revert “TST: Fetch executables from build root (GH#2551)”
(GH#7415) Elliott Sales de Andrade
OBS-URL: https://build.opensuse.org/request/show/1063268
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python:numeric/python-distributed?expand=0&rev=130
- Update to 2022.12.1
## Enhancements
* SpillBuffer metrics (GH#7368) crusaderky
* Prometheus: measure how much spilling blocks the event loop (GH#7370) crusaderky
* Add transfer_outgoing_bytes_total metric (GH#7388) Gabe Joseph
* Fail P2PShuffle gracefully upon worker failure (GH#7326) Hendrik Makait
## Bug Fixes
* Select queued tasks in stimuli, not transitions (GH#7402) Gabe Joseph
* Check ContextVar in default_client (GH#7369) Matthew Rocklin
* Fix sending event messages to non-subscribers (GH#7014) Laurence Watts
* Set sizing mode on Tabs to avoid layout collapse (GH#7365) Mateusz Paprocki
## Maintenance
* Restructure P2PShuffle extensions (GH#7390) Hendrik Makait
* Add Python 3.11 classifier (GH#7408) James Bourbeau
* Add support for Python 3.11 (GH#7249) Thomas Grainger
* Add test for using annotations with client.submit and client.map (GH#7399) James Bourbeau
* Bump actions/checkout from 3.1.0 to 3.2.0 (GH#7393)
* Remove superfluous ShuffleSchedulerExtension.barriers (GH#7389) Hendrik Makait
* Remove ignore annotation-unchecked (GH#7379) crusaderky
* Remove tornado max version from nightly recipe (GH#7376) Charles Blackmon-Luca
* Remove the experimental feature warning for Semaphore (GH#7373) Florian Jetter
- Release 2022.12.0
## Enhancements
* Expose event loop health metrics in Prometheus (GH#7360) Hendrik Makait
* Allow log propagation by default (GH#5669) Florian Jetter
* Clean up of unpack_remotedata() (GH#7322) Mads R. B. Kristensen
* Upgrade to tornado 6.2 (GH#7286) Thomas Grainger
* Introduce Server level comm counters (GH#7332) Florian Jetter
* Prometheus debug log (GH#7302) Florian Jetter
## Bug Fixes
* Catch BaseException s from user tasks (GH#5997) Gabe Joseph
* Impossible use case of erred deps in transition to waiting (GH#7354) crusaderky
* Fix a deadlock when queued tasks are resubmitted quickly in succession (GH#7348) Florian Jetter
## Maintenance
* Fetch all artifacts (GH#7355) Enrico Minack
* Delay fsspec and urllib3 import time (GH#6659) Florian Jetter
* Bump mypy (GH#7349) crusaderky
* Bump mypy and remove win specific run (GH#7344) Florian Jetter
* Finish overhaul of SchedulerState annotations (GH#7333) crusaderky
* Fix flaky test_pause_while_spilling (GH#7334) Gabe Joseph
* Update gpuCI RAPIDS_VER to 23.02 (GH#7337)
- Drop distributed-pr7286-tornado-6-2.patch
- Move to PEP517 build
OBS-URL: https://build.opensuse.org/request/show/1056224
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python:numeric/python-distributed?expand=0&rev=128
