(self, load_async)
| 3042 | @pytest.mark.asyncio |
| 3043 | @pytest.mark.parametrize("load_async", [True, False]) |
| 3044 | async def test_DaskIndexingAdapter(self, load_async): |
| 3045 | import dask.array as da |
| 3046 | |
| 3047 | dask_array = da.asarray(self.d) |
| 3048 | v = Variable(dims=("x", "y"), data=DaskIndexingAdapter(dask_array)) |
| 3049 | await self.check_orthogonal_indexing(v, load_async) |
| 3050 | await self.check_vectorized_indexing(v, load_async) |
| 3051 | # doubly wrapping |
| 3052 | v = Variable( |
| 3053 | dims=("x", "y"), |
| 3054 | data=CopyOnWriteArray(DaskIndexingAdapter(dask_array)), # type: ignore[arg-type] |
| 3055 | ) |
| 3056 | await self.check_orthogonal_indexing(v, load_async) |
| 3057 | await self.check_vectorized_indexing(v, load_async) |
| 3058 | |
| 3059 | |
| 3060 | def test_clip(var): |
nothing calls this directly
no test coverage detected