Function test_keys_from_array

dask/tests/test_delayed.py:748–756

()

def test_keys_from_array():
    pytest.importorskip("numpy")
    da = pytest.importorskip("dask.array")
    from dask.array.utils import _check_dsk

    X = da.ones((10, 10), chunks=5).to_delayed().flatten()
    xs = [delayed(inc)(x) for x in X]

    _check_dsk(xs[0].dask)


# Mostly copied from https://github.com/pytoolz/toolz/pull/220