Skip to content

Flaky test_scatter_compute_lose #6730

Open

Description

@gjoseph92

Might be a recent regression:

image

__________________________ test_scatter_compute_lose ___________________________
c = <Client: No scheduler connected>
s = <Scheduler 'tcp://127.0.0.1:53041', workers: 0, cores: 0, tasks: 0>
a = <Worker 'tcp://127.0.0.1:53042', name: 0, status: closed, stored: 2, running: 0/1, ready: 0, comm: 0, waiting: 0>
b = <Worker 'tcp://127.0.0.1:53044', name: 1, status: closed, stored: 0, running: 0/2, ready: 0, comm: 0, waiting: 0>
@gen_cluster(client=True)
asyncdeftest_scatter_compute_lose(c, s, a, b):
        [x] = await c.scatter([[1, 2, 3, 4]], workers=a.address)
        y = c.submit(inc, 1, workers=b.address)
        z = c.submit(slowadd, x, y, delay=0.2)
await asyncio.sleep(0.1)
await a.close()
with pytest.raises(CancelledError):
>           await wait(z)
E           Failed: DID NOT RAISE <class 'concurrent.futures._base.CancelledError'>
distributed/tests/test_client.py:3942: Failed
----------------------------- Captured stderr call -----------------------------
2022-07-15 17:50:19,265 - distributed.worker - WARNING - Compute Failed
Key:       slowadd-12ea486410272c2ea75c5d36876e43d0
Function:  slowadd
args:      ([1, 2, 3, 4], 2)
kwargs:    {'delay': 0.2}
Exception: 'TypeError(\'can only concatenate list (not "int") to list\')'

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions