Function test_rolling_one_element_window

dask/dataframe/dask_expr/tests/test_rolling.py:132–137

(df, pdf)

def test_rolling_one_element_window(df, pdf):
    pdf.index = pd.date_range("2000-01-01", periods=12, freq="2s")
    df = from_pandas(pdf, npartitions=3)
    result = pdf.foo.rolling("1s").count()
    expected = df.foo.rolling("1s").count()
    assert_eq(result, expected)


@pytest.mark.parametrize("window", ["2s", "5s", "20s", "10h"])