(tmpdir)
| 74 | |
| 75 | |
| 76 | def _dataframe_shuffle(tmpdir): |
| 77 | pd = pytest.importorskip("pandas") |
| 78 | dd = pytest.importorskip("dask.dataframe") |
| 79 | |
| 80 | # Perform a computation using an HLG-based shuffle |
| 81 | df = pd.DataFrame({"a": range(10), "b": range(10, 20)}) |
| 82 | return dd.from_pandas(df, npartitions=2).shuffle("a", shuffle_method="tasks") |
| 83 | |
| 84 | |
| 85 | def _dataframe_tree_reduction(tmpdir): |
nothing calls this directly
no test coverage detected
searching dependent graphs…