(func)
| 686 | ], |
| 687 | ) |
| 688 | def test_cumulative_empty_partitions(func): |
| 689 | df = pd.DataFrame({"x": [1, 2, 3, 4, 5, 6, 7, 8]}) |
| 690 | ddf = dd.from_pandas(df, npartitions=4) |
| 691 | assert_eq(func(df[df.x < 5]), func(ddf[ddf.x < 5])) |
| 692 | |
| 693 | df = pd.DataFrame({"x": [1, 2, 3, 4, None, 5, 6, None, 7, 8]}) |
| 694 | ddf = dd.from_pandas(df, npartitions=5) |
| 695 | assert_eq(func(df[df.x < 5]), func(ddf[ddf.x < 5])) |
| 696 | |
| 697 | |
| 698 | def test_dropna(): |