LocalCluster fails in Python3.11
- 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
Assessment
This issue has not been assessed yet.