Function test_from_delayed_optimizing

dask/dataframe/dask_expr/io/tests/test_delayed.py:14–19

()

def test_from_delayed_optimizing():
    parts = from_dict({"a": np.arange(300)}, npartitions=30).to_delayed()
    result = from_delayed(parts[0], meta=pd.DataFrame({"a": pd.Series(dtype=np.int64)}))
    # +1 due to an Alias for correct naming
    assert len(result.optimize().dask) == 3
    assert_eq(result, pd.DataFrame({"a": pd.Series(np.arange(10))}))


@pytest.mark.parametrize("prefix", [None, "foo"])