You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by an...@apache.org on 2024/02/09 16:18:36 UTC

(beam) branch master updated: Fix change point analysis unit test (#30244)

This is an automated email from the ASF dual-hosted git repository.

anandinguva pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 4c2b8b1e51e Fix change point analysis unit test (#30244)
4c2b8b1e51e is described below

commit 4c2b8b1e51e4e228f51faee781604a05725e486d
Author: Anand Inguva <34...@users.noreply.github.com>
AuthorDate: Fri Feb 9 16:18:28 2024 +0000

    Fix change point analysis unit test (#30244)
---
 sdks/python/apache_beam/testing/analyzers/perf_analysis_test.py | 6 ------
 1 file changed, 6 deletions(-)

diff --git a/sdks/python/apache_beam/testing/analyzers/perf_analysis_test.py b/sdks/python/apache_beam/testing/analyzers/perf_analysis_test.py
index 4ef394d4ffa..5dbeba74b7e 100644
--- a/sdks/python/apache_beam/testing/analyzers/perf_analysis_test.py
+++ b/sdks/python/apache_beam/testing/analyzers/perf_analysis_test.py
@@ -35,7 +35,6 @@ try:
   from apache_beam.testing.analyzers.perf_analysis_utils import MetricContainer
   from apache_beam.testing.analyzers.perf_analysis_utils import TestConfigContainer
   from apache_beam.testing.analyzers.perf_analysis_utils import is_change_point_in_valid_window
-  from apache_beam.testing.analyzers.perf_analysis_utils import is_edge_change_point
   from apache_beam.testing.analyzers.perf_analysis_utils import is_sibling_change_point
   from apache_beam.testing.analyzers.perf_analysis_utils import e_divisive
   from apache_beam.testing.analyzers.perf_analysis_utils import filter_change_points_by_median_threshold
@@ -266,11 +265,6 @@ class TestChangePointAnalysis(unittest.TestCase):
 
   def test_change_point_on_edge_segment(self):
     data = [1] * 50 + [100]
-    change_points = find_change_points(data)
-    self.assertEqual(change_points, [50])
-
-    self.assertEqual(is_edge_change_point(change_points[0], len(data)), True)
-
     self.assertEqual(find_latest_change_point_index(data), None)