Udate integration tests

ocelotl · Sep 8, 2023 · e16d0c0 · e16d0c0
1 parent e3b37e3
commit e16d0c0
Showing 1 changed file with 7 additions and 39 deletions.
diff --git a/opentelemetry-sdk/tests/metrics/integration_test/test_sum_aggregation.py b/opentelemetry-sdk/tests/metrics/integration_test/test_sum_aggregation.py
@@ -79,9 +79,7 @@ def observable_counter_callback(callback_options):
         self.assertEqual(counter, 10)
 
         for metrics_data in results:
-            self.assertEqual(
-                len(metrics_data.resource_metrics[0].scope_metrics), 0
-            )
+            self.assertIsNone(metrics_data)
 
         results = []
 
@@ -153,15 +151,7 @@ def observable_counter_callback(callback_options):
         provider.shutdown()
 
         for metrics_data in results:
-            self.assertEqual(
-                len(
-                    metrics_data.resource_metrics[0]
-                    .scope_metrics[0]
-                    .metrics[0]
-                    .data.data_points
-                ),
-                0,
-            )
+            self.assertIsNone(metrics_data)
 
     @mark.skipif(
         system() != "Linux",
@@ -214,9 +204,7 @@ def observable_counter_callback(callback_options):
         self.assertEqual(counter, 10)
 
         for metrics_data in results:
-            self.assertEqual(
-                len(metrics_data.resource_metrics[0].scope_metrics), 0
-            )
+            self.assertIsNone(metrics_data)
 
         results = []
 
@@ -260,15 +248,7 @@ def observable_counter_callback(callback_options):
         provider.shutdown()
 
         for metrics_data in results:
-            self.assertEqual(
-                len(
-                    metrics_data.resource_metrics[0]
-                    .scope_metrics[0]
-                    .metrics[0]
-                    .data.data_points
-                ),
-                0,
-            )
+            self.assertIsNone(metrics_data)
 
     @mark.skipif(
         system() != "Linux",
@@ -299,9 +279,7 @@ def test_synchronous_delta_temporality(self):
             results.append(reader.get_metrics_data())
 
         for metrics_data in results:
-            self.assertEqual(
-                len(metrics_data.resource_metrics[0].scope_metrics), 0
-            )
+            self.assertIsNone(metrics_data)
 
         results = []
 
@@ -369,15 +347,7 @@ def test_synchronous_delta_temporality(self):
         provider.shutdown()
 
         for metrics_data in results:
-            self.assertEqual(
-                len(
-                    metrics_data.resource_metrics[0]
-                    .scope_metrics[0]
-                    .metrics[0]
-                    .data.data_points
-                ),
-                0,
-            )
+            self.assertIsNone(metrics_data)
 
     @mark.skipif(
         system() != "Linux",
@@ -408,9 +378,7 @@ def test_synchronous_cumulative_temporality(self):
             results.append(reader.get_metrics_data())
 
         for metrics_data in results:
-            self.assertEqual(
-                len(metrics_data.resource_metrics[0].scope_metrics), 0
-            )
+            self.assertIsNone(metrics_data)
 
         results = []