dask / dask/distributed

flaky test_last_in_first_out[queue on worker]

Open
#6,216 0 comments 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

```
___________________ test_last_in_first_out[queue on worker] ____________________

c =
s =
a =
pause = False

@gen_blockable_cluster
async def test_last_in_first_out(c, s, a, pause):
async with block_worker(c, s, a, pause, 15, 5):
xs = [c.submit(slowinc, i, delay=0.05, key=f"x{i}") for i in range(5)]
ys = [c.submit(slowinc, xs[i], delay=0.05, key=f"y{i}") for i in range(5)]
zs = [c.submit(slowinc, ys[i], delay=0.05, key=f"z{i}") for i in range(5)]

while not any(s.tasks[z.key].state == "memory" for z in zs):
await asyncio.sleep(0.01)
> assert not all(s.tasks[x.key].state == "memory" for x in xs)
E assert not True
E + where True = all(. at 0x13887e500>)

distributed/tests/test_priorities.py:233: AssertionError
```

https://github.com/dask/distributed/runs/6176976855?check_suite_focus=true#step:11:1642

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.