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