| 106 | @pytest.mark.filterwarnings("ignore:\\s+Port 8787 is already in use:UserWarning") |
| 107 | @pytest.mark.parametrize("T, m", test_mdata) |
| 108 | def test_maamped_ray(T, m, ray_cluster): |
| 109 | if not RAY_IMPORTED: # pragma: no cover |
| 110 | pytest.skip("Skipping Test Ray Not Installed") |
| 111 | |
| 112 | excl_zone = int(np.ceil(m / 4)) |
| 113 | |
| 114 | ref_P, ref_I = naive.maamp(T, m, excl_zone) |
| 115 | comp_P, comp_I = maamped(ray, T, m) |
| 116 | |
| 117 | npt.assert_almost_equal(ref_P, comp_P) |
| 118 | npt.assert_almost_equal(ref_I, comp_I) |
| 119 | |
| 120 | |
| 121 | @pytest.mark.filterwarnings("ignore:numpy.dtype size changed") |