MCPcopy
hub / github.com/dask/dask / test_bagged_array_delayed

Function test_bagged_array_delayed

dask/bag/tests/test_bag.py:1644–1651  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

1642
1643
1644def test_bagged_array_delayed():
1645 pytest.importorskip("numpy")
1646 da = pytest.importorskip("dask.array")
1647
1648 obj = da.ones(10, chunks=5).to_delayed()[0]
1649 bag = db.from_delayed(obj)
1650 b = bag.compute()
1651 assert_eq(b, [1.0, 1.0, 1.0, 1.0, 1.0])
1652
1653
1654def test_dask_layers():

Callers

nothing calls this directly

Calls 5

assert_eqFunction · 0.90
from_delayedMethod · 0.80
to_delayedMethod · 0.45
onesMethod · 0.45
computeMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…