()
| 4627 | |
| 4628 | @pytest.mark.xfail(reason="we can't do this yet") |
| 4629 | def test_map_partitions_delays_large_inputs(): |
| 4630 | df = pd.DataFrame({"x": [1, 2, 3, 4]}) |
| 4631 | ddf = dd.from_pandas(df, npartitions=2) |
| 4632 | |
| 4633 | big = np.ones(1000000) |
| 4634 | |
| 4635 | b = ddf.map_partitions(lambda x, y: x, y=big) |
| 4636 | assert any(big is v for v in b.dask.values()) |
| 4637 | |
| 4638 | a = ddf.map_partitions(lambda x, y: x, big) |
| 4639 | assert any(big is v for v in a.dask.values()) |
| 4640 | |
| 4641 | |
| 4642 | def test_partitions_indexer(): |
nothing calls this directly
no test coverage detected
searching dependent graphs…