| 98 | @pytest.mark.filterwarnings("ignore:\\s+Port 8787 is already in use:UserWarning") |
| 99 | @pytest.mark.parametrize("T, m", test_data) |
| 100 | def test_maamped_df(T, m, dask_cluster): |
| 101 | with Client(dask_cluster) as dask_client: |
| 102 | excl_zone = int(np.ceil(m / 4)) |
| 103 | |
| 104 | ref_P, ref_I = naive.maamp(T, m, excl_zone) |
| 105 | df = pd.DataFrame(T.T) |
| 106 | comp_P, comp_I = maamped(dask_client, df, m) |
| 107 | |
| 108 | npt.assert_almost_equal(ref_P, comp_P) |
| 109 | npt.assert_almost_equal(ref_I, comp_I) |
| 110 | |
| 111 | |
| 112 | @pytest.mark.filterwarnings("ignore:\\s+Port 8787 is already in use:UserWarning") |