()
| 471 | |
| 472 | @pytest.mark.skipif("not dd") |
| 473 | def test_compute_delayed_dataframe(): |
| 474 | pdf = pd.DataFrame({"a": [1, 2, 3]}) |
| 475 | df = dd.from_pandas(pdf, npartitions=1) |
| 476 | dl = delayed(lambda x: None)(pdf) |
| 477 | with pytest.warns(UserWarning, match="mixed.*materialize"): |
| 478 | df_out, dl_out = compute(df, dl) |
| 479 | assert dl_out is None |
| 480 | dd.utils.assert_eq(df_out, pdf) |
| 481 | |
| 482 | |
| 483 | @pytest.mark.skipif("not dd") |