___________________ test_last_in_first_out[queue on worker] ____________________

c = <Client: No scheduler connected>
s = <Scheduler 'tcp://127.0.0.1:59925', workers: 0, cores: 0, tasks: 0>
a = <Worker 'tcp://127.0.0.1:59926', name: 0, status: closed, stored: 0, running: 1/1, ready: 2, comm: 0, waiting: 0>
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(<generator object test_last_in_first_out.<locals>.<genexpr> at 0x13887e500>)

distributed/tests/test_priorities.py:233: AssertionError