Hendrik Makait

Unpack `namedtuple`

1

This PR adds support for unpacking `namedtuple`s in `unpack_collections` and `to_task_graph`. - [ ] Closes #xxxx - [x] Tests added / passed - [x] Passes `pre-commit run --all-files`

Deprecate unpacking `dataclass` in favor of `namedtuple`

3

As mentioned in https://github.com/dask/dask/pull/9345#issuecomment-1207863896, we currently unpack `dataclass`es to discover embedded Dask collections. However, the support for `dataclass`es is limited: >[W]e basically want to be able to unpack those `dataclass`es...

flaky `test_quiet_close_process[True]`

2

``` _______________________ test_quiet_close_process[True] ________________________ processes = True tmp_path = WindowsPath('C:/Users/runneradmin/AppData/Local/Temp/pytest-of-runneradmin/pytest-0/test_quiet_close_process_True_0') @pytest.mark.slow @pytest.mark.parametrize("processes", [True, False]) def test_quiet_close_process(processes, tmp_path): with open(tmp_path / "script.py", mode="w") as f: f.write(client_script % processes) with popen([sys.executable, tmp_path...

Always return `ws.address` from `_remove_from_processing`

1

Closes #6874 - [x] Tests added / passed - [x] Passes `pre-commit run --all-files`

https://github.com/dask/distributed/blob/main/distributed/dashboard/components/scheduler.py#L3293 fails if `ts.erred_on` is `None`. ``` Aug 11 13:40:51 ip-10-0-9-12 cloud-init[1262]: 2022-08-11 13:40:51,814 - bokeh.util.tornado - ERROR - Error thrown from periodic callback: Aug 11 13:40:51 ip-10-0-9-12 cloud-init[1262]: 2022-08-11...

`AssertionError` in `WorkerState._transition_cancelled_error`

3

``` Aug 11 10:00:05 ip-10-0-3-173 cloud-init[1264]: Exception in callback Worker._handle_stimulus_from_task(

``` Aug 11 09:49:57 ip-10-0-12-62 cloud-init[1268]: 2022-08-11 09:49:57,015 - bokeh.core.property.validation - ERROR - 'start' Aug 11 09:49:57 ip-10-0-12-62 cloud-init[1268]: Traceback (most recent call last): Aug 11 09:49:57 ip-10-0-12-62 cloud-init[1268]: File...

It would be helpful to see how much disk is available for further spilling on the `/workers` dashboard. This way, the user can gauge the utilization of the disk and...

As mentioned in https://github.com/dask/distributed/issues/6536#issuecomment-1208144451, it would be useful for `Client.get_versions` to get the versions of all other clients and be able to compare against those to detect another client with...

Should `utils_test.py` be considered public API?

14

We currently expose a number of functions and fixtures in `distributed.utils_test`. While I would consider these implementation details of our tests, and not part of any stable user-facing API, other...