c291175a975dfb9376724ececba10fcc9e2e43c0,distributed/tests/test_failed_workers.py,,test_multiple_clients_restart,#Any#Any#Any#,268

Before Change

    assert x.cancelled()
    assert y.cancelled()

    yield e1._close(fast=True)
    yield e2._close(fast=True)


@gen_cluster(Worker=Nanny, timeout=60)

After Change

    assert x.cancelled()
    start = time()
    while not y.cancelled():
        yield gen.sleep(0.01)
        assert time() < start + 5

    yield c1.close()
    yield c2.close()

Instances