Function test_dont_fuse_numpy_arrays

dask/array/tests/test_optimization.py:111–123

()

def test_dont_fuse_numpy_arrays():
    x = np.ones(10)
    for _ in [(5,), (10,)]:
        y = da.from_array(x, chunks=(10,))

        dsk = y.__dask_optimize__(y.dask, y.__dask_keys__())
        assert (
            sum(
                isinstance(v, DataNode) and isinstance(v.value, np.ndarray)
                for v in dsk.values()
            )
            == 1
        )


def test_fuse_slices_with_alias():