()
| 4456 | |
| 4457 | |
| 4458 | def test_sample_empty_partitions(): |
| 4459 | @dask.delayed |
| 4460 | def make_df(n): |
| 4461 | return pd.DataFrame(np.zeros((n, 4)), columns=list("abcd")) |
| 4462 | |
| 4463 | ddf = dd.from_delayed([make_df(0), make_df(100), make_df(0)]) |
| 4464 | ddf2 = ddf.sample(frac=0.2) |
| 4465 | # smoke test sample on empty partitions |
| 4466 | res = ddf2.compute() |
| 4467 | assert res.dtypes.equals(ddf2.dtypes) |
| 4468 | |
| 4469 | |
| 4470 | def test_coerce(): |
nothing calls this directly
no test coverage detected