()
| 5 | |
| 6 | |
| 7 | def test_map_blocks_block_id_fusion(): |
| 8 | arr = da.ones((20, 10), chunks=(2, 5)) |
| 9 | |
| 10 | def dummy(x, block_id=None, block_info=None): |
| 11 | return x |
| 12 | |
| 13 | result = arr.map_blocks(dummy).astype("f8") |
| 14 | dsk = collections_to_expr([result]) |
| 15 | assert len(dsk.__dask_graph__()) == 20 |
nothing calls this directly
no test coverage detected