Skip to content

Commit 092daa6

Browse files
committed
remove dead test code
1 parent bc90dea commit 092daa6

1 file changed

Lines changed: 0 additions & 44 deletions

File tree

distributed/tests/test_client.py

Lines changed: 0 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -4509,50 +4509,6 @@ def test_normalize_collection_with_released_futures(c):
45094509
assert res == sol
45104510

45114511

4512-
@pytest.mark.xfail(reason="https://github.com/dask/distributed/issues/4404")
4513-
@gen_cluster(client=True)
4514-
async def test_auto_normalize_collection(c, s, a, b):
4515-
da = pytest.importorskip("dask.array")
4516-
4517-
x = da.ones(10, chunks=5)
4518-
assert len(x.dask) == 2
4519-
4520-
with dask.config.set(optimizations=[c._optimize_insert_futures]):
4521-
y = x.map_blocks(inc, dtype=x.dtype)
4522-
yy = c.persist(y)
4523-
4524-
await wait(yy)
4525-
4526-
start = time()
4527-
future = c.compute(y.sum())
4528-
await future
4529-
end = time()
4530-
assert end - start < 1
4531-
4532-
start = time()
4533-
z = c.persist(y + 1)
4534-
await wait(z)
4535-
end = time()
4536-
assert end - start < 1
4537-
4538-
4539-
@pytest.mark.xfail(reason="https://github.com/dask/distributed/issues/4404")
4540-
def test_auto_normalize_collection_sync(c):
4541-
da = pytest.importorskip("dask.array")
4542-
x = da.ones(10, chunks=5)
4543-
4544-
y = x.map_blocks(inc, dtype=x.dtype)
4545-
yy = c.persist(y)
4546-
4547-
wait(yy)
4548-
4549-
with dask.config.set(optimizations=[c._optimize_insert_futures]):
4550-
start = time()
4551-
y.sum().compute()
4552-
end = time()
4553-
assert end - start < 1
4554-
4555-
45564512
def assert_no_data_loss(scheduler):
45574513
for key, start, finish, recommendations, _, _ in scheduler.transition_log:
45584514
if start == "memory" and finish == "released":

0 commit comments

Comments
 (0)