(optimize)
| 2406 | |
| 2407 | @pytest.mark.parametrize("optimize", [True, False]) |
| 2408 | def test_delayed_roundtrip(optimize): |
| 2409 | df1 = d + 1 + 1 |
| 2410 | delayed = df1.to_delayed(optimize_graph=optimize) |
| 2411 | |
| 2412 | assert len(delayed) == df1.npartitions |
| 2413 | dm = d.a.mean().to_delayed(optimize_graph=optimize) |
| 2414 | |
| 2415 | delayed2 = [x * 2 - dm for x in delayed] |
| 2416 | |
| 2417 | for x in delayed2: |
| 2418 | x.dask.validate() |
| 2419 | |
| 2420 | df3 = dd.from_delayed(delayed2, meta=df1, divisions=df1.divisions) |
| 2421 | df4 = df3 - 1 - 1 |
| 2422 | assert_eq(df4, (full + 2) * 2 - full.a.mean() - 2) |
| 2423 | |
| 2424 | |
| 2425 | def test_from_delayed_lazy_if_meta_provided(): |
nothing calls this directly
no test coverage detected