()
| 153 | |
| 154 | @pytest.mark.xfail(reason="blockwise fusion does not respect this, which is ok") |
| 155 | def test_turn_off_fusion(): |
| 156 | x = da.ones(10, chunks=(5,)) |
| 157 | y = da.sum(x + 1 + 2 + 3) |
| 158 | |
| 159 | a = y.__dask_optimize__(y.dask, y.__dask_keys__()) |
| 160 | |
| 161 | with dask.config.set({"optimization.fuse.ave-width": 0}): |
| 162 | b = y.__dask_optimize__(y.dask, y.__dask_keys__()) |
| 163 | |
| 164 | assert dask.get(a, y.__dask_keys__()) == dask.get(b, y.__dask_keys__()) |
| 165 | assert len(a) < len(b) |
| 166 | |
| 167 | |
| 168 | def test_disable_lowlevel_fusion(): |
nothing calls this directly
no test coverage detected