From 6a81afaa9cee7dc9079b7948ec002b879704df27 Mon Sep 17 00:00:00 2001
From: Diego Hurtado <ocelotl@users.noreply.github.com>
Date: Fri, 6 Oct 2023 00:03:48 +0200
Subject: [PATCH] Use sleep to avoid resolution errors in Windows

---
 .../integration_test/test_sum_aggregation.py  | 50 ++++---------------
 1 file changed, 10 insertions(+), 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
index e478d75c081..0dbb37b0893 100644
--- 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,7 +319,7 @@ def test_synchronous_delta_temporality(self):
         results = []
 
         for _ in range(10):
-
+            sleep(0)
             results.append(reader.get_metrics_data())
 
         provider.shutdown()
@@ -349,14 +327,6 @@ def test_synchronous_delta_temporality(self):
         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()