()
| 497 | |
| 498 | @pytest.mark.skipif("not da") |
| 499 | def test_compute_array_bag(): |
| 500 | x = da.arange(5, chunks=2) |
| 501 | b = db.from_sequence([1, 2, 3]) |
| 502 | |
| 503 | pytest.raises(ValueError, lambda: compute(x, b)) |
| 504 | |
| 505 | xx, bb = compute(x, b, scheduler="single-threaded") |
| 506 | assert np.allclose(xx, np.arange(5)) |
| 507 | assert bb == [1, 2, 3] |
| 508 | |
| 509 | |
| 510 | @pytest.mark.skipif("not da") |