()
| 4443 | |
| 4444 | |
| 4445 | def test_sample_empty_partitions(): |
| 4446 | @dask.delayed |
| 4447 | def make_df(n): |
| 4448 | return pd.DataFrame(np.zeros((n, 4)), columns=list("abcd")) |
| 4449 | |
| 4450 | ddf = dd.from_delayed([make_df(0), make_df(100), make_df(0)]) |
| 4451 | ddf2 = ddf.sample(frac=0.2) |
| 4452 | # smoke test sample on empty partitions |
| 4453 | res = ddf2.compute() |
| 4454 | assert res.dtypes.equals(ddf2.dtypes) |
| 4455 | |
| 4456 | |
| 4457 | def test_coerce(): |
nothing calls this directly
no test coverage detected