(dask_cluster)
| 130 | |
| 131 | @pytest.mark.filterwarnings("ignore:\\s+Port 8787 is already in use:UserWarning") |
| 132 | def test_mstumped_identical_subsequence_self_join(dask_cluster): |
| 133 | with Client(dask_cluster) as dask_client: |
| 134 | identical = np.random.rand(8) |
| 135 | T_A = np.random.rand(20) |
| 136 | T_A[1 : 1 + identical.shape[0]] = identical |
| 137 | T_A[11 : 11 + identical.shape[0]] = identical |
| 138 | T = np.array([T_A, T_A, np.random.rand(T_A.shape[0])]) |
| 139 | m = 3 |
| 140 | |
| 141 | excl_zone = int(np.ceil(m / 4)) |
| 142 | |
| 143 | ref_P, ref_I = naive.mstump(T, m, excl_zone) |
| 144 | comp_P, comp_I = mstumped(dask_client, T, m) |
| 145 | |
| 146 | npt.assert_almost_equal( |
| 147 | ref_P, comp_P, decimal=config.STUMPY_TEST_PRECISION |
| 148 | ) # ignore indices |
| 149 | |
| 150 | |
| 151 | @pytest.mark.filterwarnings("ignore:\\s+Port 8787 is already in use:UserWarning") |
nothing calls this directly
no test coverage detected