| 626 | |
| 627 | |
| 628 | def test_array_bag_delayed(): |
| 629 | np = pytest.importorskip("numpy") |
| 630 | da = pytest.importorskip("dask.array") |
| 631 | |
| 632 | arr1 = np.arange(100).reshape((10, 10)) |
| 633 | arr2 = arr1.dot(arr1.T) |
| 634 | darr1 = da.from_array(arr1, chunks=(5, 5)) |
| 635 | darr2 = da.from_array(arr2, chunks=(5, 5)) |
| 636 | b = db.from_sequence([1, 2, 3]) |
| 637 | seq = [arr1, arr2, darr1, darr2, b] |
| 638 | out = delayed(sum)([i.sum() for i in seq]) |
| 639 | assert out.compute() == 2 * arr1.sum() + 2 * arr2.sum() + sum([1, 2, 3]) |
| 640 | |
| 641 | |
| 642 | def test_delayed_picklable(): |