dask / dask/distributed

LocalCluster fails in Python3.11

Open
#7,211 3 comments 3 reactions 0 assignees View on GitHub
Dominant language
Python
Stars
1.7k
Forks
778
Avg merge
2h 50m
Merged PRs (30d)
3

Description

OS: Windows 10 64 bit
Python: 3.11.0
Dask: 2022.10.0

```
>>> from dask.distributed import LocalCluster
>>> cluster = LocalCluster()
Traceback (most recent call last):
File "E:\Envs\task_management311\Lib\site-packages\distributed\deploy\spec.py", line 277, in __init__
self.sync(self._correct_state)
File "E:\Envs\task_management311\Lib\site-packages\distributed\utils.py", line 339, in sync
return sync(
^^^^^
File "E:\Envs\task_management311\Lib\site-packages\distributed\utils.py", line 406, in sync
raise exc.with_traceback(tb)
File "E:\Envs\task_management311\Lib\site-packages\distributed\utils.py", line 379, in f
result = yield future
^^^^^^^^^^^^
File "E:\Envs\task_management311\Lib\site-packages\tornado\gen.py", line 762, in run
value = future.result()
^^^^^^^^^^^^^^^
File "E:\Envs\task_management311\Lib\site-packages\distributed\deploy\spec.py", line 366, in _correct_state_internal
await asyncio.wait(workers)
File "C:\Python311\Lib\asyncio\tasks.py", line 418, in wait
return await _wait(fs, timeout, return_when, loop)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Python311\Lib\asyncio\tasks.py", line 522, in _wait
f.add_done_callback(_on_completion)
^^^^^^^^^^^^^^^^^^^
AttributeError: 'Nanny' object has no attribute 'add_done_callback'

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
File "", line 1, in
File "E:\Envs\task_management311\Lib\site-packages\distributed\deploy\local.py", line 251, in __init__
super().__init__(
File "E:\Envs\task_management311\Lib\site-packages\distributed\deploy\spec.py", line 279, in __init__
self.sync(self.close)
File "E:\Envs\task_management311\Lib\site-packages\distributed\utils.py", line 339, in sync
return sync(
^^^^^
File "E:\Envs\task_management311\Lib\site-packages\distributed\utils.py", line 406, in sync
raise exc.with_traceback(tb)
File "E:\Envs\task_management311\Lib\site-packages\distributed\utils.py", line 379, in f
result = yield future
^^^^^^^^^^^^
File "E:\Envs\task_management311\Lib\site-packages\tornado\gen.py", line 762, in run
value = future.result()
^^^^^^^^^^^^^^^
File "E:\Envs\task_management311\Lib\site-packages\distributed\deploy\spec.py", line 437, in _close
assert w.status in {
AssertionError: Status.init

```

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.