Use sleep to avoid resolution errors in Windows

ocelotl · Oct 5, 2023 · 6a81afa · 6a81afa
1 parent 3fae820
commit 6a81afa
Showing 1 changed file with 10 additions and 40 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
@@ -14,6 +14,7 @@
 
 from itertools import count
 from platform import system
+from time import sleep
 from unittest import TestCase
 
 from pytest import mark
@@ -28,14 +29,6 @@
 
 
 class TestSumAggregation(TestCase):
-    @mark.skipif(
-        system() != "Linux",
-        reason=(
-            "Tests fail because Windows time_ns resolution is too low so "
-            "two different time measurements may end up having the exact same"
-            "value."
-        ),
-    )
     def test_asynchronous_delta_temporality(self):
 
         eight_multiple_generator = count(start=8, step=8)
@@ -73,7 +66,7 @@ def observable_counter_callback(callback_options):
         results = []
 
         for _ in range(10):
-
+            sleep(0)
             results.append(reader.get_metrics_data())
 
         self.assertEqual(counter, 10)
@@ -84,7 +77,7 @@ def observable_counter_callback(callback_options):
         results = []
 
         for _ in range(10):
-
+            sleep(0)
             results.append(reader.get_metrics_data())
 
         self.assertEqual(counter, 20)
@@ -143,7 +136,7 @@ def observable_counter_callback(callback_options):
         results = []
 
         for _ in range(10):
-
+            sleep(0)
             results.append(reader.get_metrics_data())
 
         self.assertEqual(counter, 30)
@@ -153,14 +146,6 @@ def observable_counter_callback(callback_options):
         for metrics_data in results:
             self.assertIsNone(metrics_data)
 
-    @mark.skipif(
-        system() != "Linux",
-        reason=(
-            "Tests fail because Windows time_ns resolution is too low so "
-            "two different time measurements may end up having the exact same"
-            "value."
-        ),
-    )
     def test_asynchronous_cumulative_temporality(self):
 
         eight_multiple_generator = count(start=8, step=8)
@@ -198,7 +183,7 @@ def observable_counter_callback(callback_options):
         results = []
 
         for _ in range(10):
-
+            sleep(0)
             results.append(reader.get_metrics_data())
 
         self.assertEqual(counter, 10)
@@ -209,7 +194,7 @@ def observable_counter_callback(callback_options):
         results = []
 
         for _ in range(10):
-
+            sleep(0)
             results.append(reader.get_metrics_data())
 
         self.assertEqual(counter, 20)
@@ -240,7 +225,7 @@ def observable_counter_callback(callback_options):
         results = []
 
         for _ in range(10):
-
+            sleep(0)
             results.append(reader.get_metrics_data())
 
         self.assertEqual(counter, 30)
@@ -250,14 +235,6 @@ def observable_counter_callback(callback_options):
         for metrics_data in results:
             self.assertIsNone(metrics_data)
 
-    @mark.skipif(
-        system() != "Linux",
-        reason=(
-            "Tests fail because Windows time_ns resolution is too low so "
-            "two different time measurements may end up having the exact same"
-            "value."
-        ),
-    )
     def test_synchronous_delta_temporality(self):
 
         aggregation = SumAggregation()
@@ -275,7 +252,7 @@ def test_synchronous_delta_temporality(self):
         results = []
 
         for _ in range(10):
-
+            sleep(0)
             results.append(reader.get_metrics_data())
 
         for metrics_data in results:
@@ -285,6 +262,7 @@ def test_synchronous_delta_temporality(self):
 
         for _ in range(10):
             counter.add(8)
+            sleep(0)
             results.append(reader.get_metrics_data())
 
         previous_time_unix_nano = (
@@ -341,22 +319,14 @@ def test_synchronous_delta_temporality(self):
         results = []
 
         for _ in range(10):
-
+            sleep(0)
             results.append(reader.get_metrics_data())
 
         provider.shutdown()
 
         for metrics_data in results:
             self.assertIsNone(metrics_data)
 
-    @mark.skipif(
-        system() != "Linux",
-        reason=(
-            "Tests fail because Windows time_ns resolution is too low so "
-            "two different time measurements may end up having the exact same"
-            "value."
-        ),
-    )
     def test_synchronous_cumulative_temporality(self):
 
         aggregation = SumAggregation()