()
| 486 | |
| 487 | @pytest.mark.skipif("not da") |
| 488 | def test_compute_array_bag(): |
| 489 | x = da.arange(5, chunks=2) |
| 490 | b = db.from_sequence([1, 2, 3]) |
| 491 | |
| 492 | pytest.raises(ValueError, lambda: compute(x, b)) |
| 493 | |
| 494 | xx, bb = compute(x, b, scheduler="single-threaded") |
| 495 | assert np.allclose(xx, np.arange(5)) |
| 496 | assert bb == [1, 2, 3] |
| 497 | |
| 498 | |
| 499 | @pytest.mark.skipif("not da") |