dask / dask/distributed

Flaky tests: plain `TimeoutError` during client connection to scheduler

Open
#6,757 1 comment 0 reactions 0 assignees View on GitHub
flaky test
Dominant language
Python
Stars
1.7k
Forks
778
Avg merge
2h 50m
Merged PRs (30d)
3

Description

Manifests as a CancelledError from `Comm.read`:
```
> frames_nbytes = await stream.read_bytes(fmt_size)
E asyncio.exceptions.CancelledError
```
Which eventually comes out as a `TimeoutError` from `asyncio.wait_for`:
```
except exceptions.CancelledError as exc:
> raise exceptions.TimeoutError() fromexc
E asyncio.exceptions.TimeoutError
```
Then, tearing down the test times out after 10s waiting for all global clients to close:
```
whileset(_global_clients):
sleep(0.1)
> assert time() < start + 10
E assert 1657573967.6341991 < (1657573957.571699 + 10)
E + where 1657573967.6341991 = time()
```

I would imagine the underlying cause is related to (or even the same as) https://github.com/dask/distributed/issues/6731.

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.