Fix variable name

Author: DylanRussell

exporter/opentelemetry-exporter-otlp-proto-grpc/tests/test_otlp_exporter_mixin.py

@@ -347,9 +347,9 @@ def test_shutdown_interrupts_export_retry_backoff(self):
             time.sleep(0.05)
             # The code should now be in a 1 second backoff.
             # pylint: disable=protected-access
-            self.assertFalse(self.exporter._shutdown_is_occuring.is_set())
+            self.assertFalse(self.exporter._shutdown_in_progress.is_set())
             self.exporter.shutdown()
-            self.assertTrue(self.exporter._shutdown_is_occuring.is_set())
+            self.assertTrue(self.exporter._shutdown_in_progress.is_set())
             export_result = export_thread.join()
             end_wait = time.time()
             self.assertEqual(export_result, SpanExportResult.FAILURE)

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/metric_exporter/__init__.py

@@ -121,7 +121,7 @@ def __init__(
         | None = None,
         preferred_aggregation: dict[type, Aggregation] | None = None,
     ):
-        self._shutdown_is_occuring = threading.Event()
+        self._shutdown_in_progress = threading.Event()
         self._endpoint = endpoint or environ.get(
             OTEL_EXPORTER_OTLP_METRICS_ENDPOINT,
             _append_metrics_path(
@@ -238,7 +238,7 @@ def export(
                 resp.reason,
                 backoff_seconds,
             )
-            shutdown = self._shutdown_is_occuring.wait(backoff_seconds)
+            shutdown = self._shutdown_in_progress.wait(backoff_seconds)
             if shutdown:
                 _logger.warning("Shutdown in progress, aborting retry.")
                 break
@@ -249,7 +249,7 @@ def shutdown(self, timeout_millis: float = 30_000, **kwargs) -> None:
             _logger.warning("Exporter already shutdown, ignoring call")
             return
         self._shutdown = True
-        self._shutdown_is_occuring.set()
+        self._shutdown_in_progress.set()
         self._session.close()
 
     @property

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/trace_exporter/__init__.py

@@ -77,7 +77,7 @@ def __init__(
         compression: Optional[Compression] = None,
         session: Optional[requests.Session] = None,
     ):
-        self._shutdown_is_occuring = threading.Event()
+        self._shutdown_in_progress = threading.Event()
         self._endpoint = endpoint or environ.get(
             OTEL_EXPORTER_OTLP_TRACES_ENDPOINT,
             _append_trace_path(
@@ -186,7 +186,7 @@ def export(self, spans: Sequence[ReadableSpan]) -> SpanExportResult:
                 resp.reason,
                 backoff_seconds,
             )
-            shutdown = self._shutdown_is_occuring.wait(backoff_seconds)
+            shutdown = self._shutdown_in_progress.wait(backoff_seconds)
             if shutdown:
                 _logger.warning("Shutdown in progress, aborting retry.")
                 break
@@ -197,7 +197,7 @@ def shutdown(self):
             _logger.warning("Exporter already shutdown, ignoring call")
             return
         self._shutdown = True
-        self._shutdown_is_occuring.set()
+        self._shutdown_in_progress.set()
         self._session.close()
 
     def force_flush(self, timeout_millis: int = 30000) -> bool: