(dsk, keys, expected, **kwargs)
| 94 | pytest.importorskip("zarr") |
| 95 | |
| 96 | def custom_scheduler_get(dsk, keys, expected, **kwargs): |
| 97 | dsk = dsk.__dask_graph__() |
| 98 | assert ( |
| 99 | len(dsk) == expected |
| 100 | ), f"False number of tasks got {len(dsk)} but expected {expected}" |
| 101 | return [42 for _ in keys] |
| 102 | |
| 103 | # First test that this mocking stuff works as expecged |
| 104 | with pytest.raises(AssertionError, match="False number of tasks"): |
nothing calls this directly
no test coverage detected