()
| 387 | |
| 388 | @pytest.mark.skipif("not da") |
| 389 | def test_persist_array(): |
| 390 | from dask.array.utils import assert_eq |
| 391 | |
| 392 | arr = np.arange(100).reshape((10, 10)) |
| 393 | x = da.from_array(arr, chunks=(5, 5)) |
| 394 | x = (x + 1) - x.mean(axis=0) |
| 395 | y = x.persist() |
| 396 | |
| 397 | assert_eq(x, y) |
| 398 | assert set(y.dask).issubset(x.dask) |
| 399 | assert len(y.dask) == y.npartitions |
| 400 | |
| 401 | |
| 402 | @pytest.mark.skipif("not da") |