fix _time_ns import

opentelemetry-sdk/src/opentelemetry/sdk/_metrics/_internal/__init__.py

@@ -48,7 +48,7 @@
 from opentelemetry.sdk.resources import Resource
 from opentelemetry.sdk.util.instrumentation import InstrumentationScope
 from opentelemetry.util._once import Once
-from opentelemetry.util._time import time_ns
+from opentelemetry.util._time import _time_ns
 
 _logger = getLogger(__name__)
 
@@ -371,10 +371,10 @@ def __init__(
         self._shutdown = False
 
     def force_flush(self, timeout_millis: float = 10_000) -> bool:
-        deadline_ns = time_ns() + timeout_millis * 10**6
+        deadline_ns = _time_ns() + timeout_millis * 10**6
 
         for metric_reader in self._sdk_config.metric_readers:
-            current_ts = time_ns()
+            current_ts = _time_ns()
             if current_ts >= deadline_ns:
                 raise Exception("Timed out while flushing metric readers")
             metric_reader.collect(
@@ -383,7 +383,7 @@ def force_flush(self, timeout_millis: float = 10_000) -> bool:
         return True
 
     def shutdown(self, timeout_millis: float = 30_000):
-        deadline_ns = time_ns() + timeout_millis * 10**6
+        deadline_ns = _time_ns() + timeout_millis * 10**6
 
         def _shutdown():
             self._shutdown = True
@@ -397,7 +397,7 @@ def _shutdown():
         metric_reader_error = {}
 
         for metric_reader in self._sdk_config.metric_readers:
-            current_ts = time_ns()
+            current_ts = _time_ns()
             try:
                 if current_ts >= deadline_ns:
                     raise Exception(

opentelemetry-sdk/src/opentelemetry/sdk/_metrics/_internal/export/__init__.py

@@ -31,7 +31,7 @@
 from opentelemetry.sdk._metrics.metric_reader import MetricReader
 from opentelemetry.sdk._metrics.point import AggregationTemporality, Metric
 from opentelemetry.util._once import Once
-from opentelemetry.util._time import time_ns
+from opentelemetry.util._time import _time_ns
 
 _logger = logging.getLogger(__name__)
 
@@ -225,7 +225,7 @@ def _receive_metrics(
         detach(token)
 
     def shutdown(self, timeout_millis: float = 30_000, **kwargs) -> None:
-        deadline_ns = time_ns() + timeout_millis * 10**6
+        deadline_ns = _time_ns() + timeout_millis * 10**6
 
         def _shutdown():
             self._shutdown = True
@@ -236,5 +236,5 @@ def _shutdown():
             return
 
         self._shutdown_event.set()
-        self._daemon_thread.join(timeout=(deadline_ns - time_ns()) / 10**9)
-        self._exporter.shutdown(timeout=(deadline_ns - time_ns()) / 10**6)
+        self._daemon_thread.join(timeout=(deadline_ns - _time_ns()) / 10**9)
+        self._exporter.shutdown(timeout=(deadline_ns - _time_ns()) / 10**6)