Skip to content

Commit 21b80ed

Browse files
committed
Remove pointless test
1 parent bf8e641 commit 21b80ed

1 file changed

Lines changed: 0 additions & 34 deletions

File tree

distributed/tests/test_resources.py

Lines changed: 0 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -463,40 +463,6 @@ async def test_full_collections(c, s, a, b):
463463
assert not b.state.log
464464

465465

466-
@pytest.mark.parametrize(
467-
"optimize_graph",
468-
[
469-
pytest.param(
470-
True,
471-
marks=pytest.mark.xfail(
472-
reason="don't track resources through optimization"
473-
),
474-
),
475-
False,
476-
],
477-
)
478-
def test_collections_get(client, optimize_graph, s, a, b):
479-
pytest.importorskip("numpy")
480-
da = pytest.importorskip("dask.array")
481-
482-
async def f(dask_worker):
483-
await dask_worker.set_resources(**{"A": 1})
484-
485-
client.run(f, workers=[a["address"]])
486-
487-
with dask.annotate(resources={"A": 1}):
488-
x = da.random.random(100, chunks=(10,)) + 1
489-
490-
x.compute(optimize_graph=optimize_graph)
491-
492-
def g(dask_worker):
493-
return len(dask_worker.log)
494-
495-
logs = client.run(g)
496-
assert logs[a["address"]]
497-
assert not logs[b["address"]]
498-
499-
500466
@gen_cluster(config={"distributed.worker.resources.my_resources": 1}, client=True)
501467
async def test_resources_from_config(c, s, a, b):
502468
info = c.scheduler_info()

0 commit comments

Comments
 (0)