Function test_aamped_self_join_larger_window

tests/test_aamped.py:83–91

(T_A, T_B, m, dask_cluster)

@pytest.mark.parametrize("T_A, T_B", test_data)
@pytest.mark.parametrize("m", window_size)
def test_aamped_self_join_larger_window(T_A, T_B, m, dask_cluster):
    with Client(dask_cluster) as dask_client:
        if len(T_B) > m:
            ref_mp = naive.aamp(T_B, m)
            comp_mp = aamped(dask_client, T_B, m)
            naive.replace_inf(ref_mp)
            naive.replace_inf(comp_mp)

            npt.assert_almost_equal(ref_mp, comp_mp)


@pytest.mark.filterwarnings("ignore:numpy.dtype size changed")