(self)
| 656 | self.assertLazyAndEqual(expected, DataArray(x).where(y)) |
| 657 | |
| 658 | def test_simultaneous_compute(self): |
| 659 | ds = Dataset({"foo": ("x", range(5)), "bar": ("x", range(5))}).chunk() |
| 660 | |
| 661 | count = [0] |
| 662 | |
| 663 | def counting_get(*args, **kwargs): |
| 664 | count[0] += 1 |
| 665 | return dask.get(*args, **kwargs) |
| 666 | |
| 667 | ds.load(scheduler=counting_get) |
| 668 | |
| 669 | assert count[0] == 1 |
| 670 | |
| 671 | def test_duplicate_dims(self): |
| 672 | data = np.random.normal(size=(4, 4)) |