Run precommit

Author: DylanRussell

opentelemetry-sdk/src/opentelemetry/sdk/_shared_internal/__init__.py

@@ -21,7 +21,9 @@
 import threading
 import weakref
 from typing import (
+    Generic,
     Optional,
+    TypeVar,
 )
 
 from opentelemetry.context import (
@@ -30,7 +32,6 @@
     detach,
     set_value,
 )
-from typing import TypeVar, Generic
 from opentelemetry.util._once import Once
 
 

opentelemetry-sdk/tests/logs/test_export.py

@@ -351,11 +351,21 @@ def test_args(self):
             max_export_batch_size=256,
             export_timeout_millis=15000,
         )
-        self.assertEqual(log_record_processor._batch_processor._exporter, exporter)
-        self.assertEqual(log_record_processor._batch_processor._max_queue_size, 1024)
-        self.assertEqual(log_record_processor._batch_processor._schedule_delay, 2.5)
-        self.assertEqual(log_record_processor._batch_processor._max_export_batch_size, 256)
-        self.assertEqual(log_record_processor._batch_processor._export_timeout_millis, 15000)
+        self.assertEqual(
+            log_record_processor._batch_processor._exporter, exporter
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._max_queue_size, 1024
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._schedule_delay, 2.5
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._max_export_batch_size, 256
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._export_timeout_millis, 15000
+        )
 
     @patch.dict(
         "os.environ",
@@ -369,20 +379,40 @@ def test_args(self):
     def test_env_vars(self):
         exporter = InMemoryLogExporter()
         log_record_processor = BatchLogRecordProcessor(exporter)
-        self.assertEqual(log_record_processor._batch_processor._exporter, exporter)
-        self.assertEqual(log_record_processor._batch_processor._max_queue_size, 1024)
-        self.assertEqual(log_record_processor._batch_processor._schedule_delay, 2.5)
-        self.assertEqual(log_record_processor._batch_processor._max_export_batch_size, 256)
-        self.assertEqual(log_record_processor._batch_processor._export_timeout_millis, 15000)
+        self.assertEqual(
+            log_record_processor._batch_processor._exporter, exporter
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._max_queue_size, 1024
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._schedule_delay, 2.5
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._max_export_batch_size, 256
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._export_timeout_millis, 15000
+        )
 
     def test_args_defaults(self):
         exporter = InMemoryLogExporter()
         log_record_processor = BatchLogRecordProcessor(exporter)
-        self.assertEqual(log_record_processor._batch_processor._exporter, exporter)
-        self.assertEqual(log_record_processor._batch_processor._max_queue_size, 2048)
-        self.assertEqual(log_record_processor._batch_processor._schedule_delay, 5)
-        self.assertEqual(log_record_processor._batch_processor._max_export_batch_size, 512)
-        self.assertEqual(log_record_processor._batch_processor._export_timeout_millis, 30000)
+        self.assertEqual(
+            log_record_processor._batch_processor._exporter, exporter
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._max_queue_size, 2048
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._schedule_delay, 5
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._max_export_batch_size, 512
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._export_timeout_millis, 30000
+        )
 
     @patch.dict(
         "os.environ",
@@ -398,11 +428,21 @@ def test_args_env_var_value_error(self):
         _logger.disabled = True
         log_record_processor = BatchLogRecordProcessor(exporter)
         _logger.disabled = False
-        self.assertEqual(log_record_processor._batch_processor._exporter, exporter)
-        self.assertEqual(log_record_processor._batch_processor._max_queue_size, 2048)
-        self.assertEqual(log_record_processor._batch_processor._schedule_delay, 5)
-        self.assertEqual(log_record_processor._batch_processor._max_export_batch_size, 512)
-        self.assertEqual(log_record_processor._batch_processor._export_timeout_millis, 30000)
+        self.assertEqual(
+            log_record_processor._batch_processor._exporter, exporter
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._max_queue_size, 2048
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._schedule_delay, 5
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._max_export_batch_size, 512
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._export_timeout_millis, 30000
+        )
 
     def test_args_none_defaults(self):
         exporter = InMemoryLogExporter()
@@ -413,11 +453,21 @@ def test_args_none_defaults(self):
             max_export_batch_size=None,
             export_timeout_millis=None,
         )
-        self.assertEqual(log_record_processor._batch_processor._exporter, exporter)
-        self.assertEqual(log_record_processor._batch_processor._max_queue_size, 2048)
-        self.assertEqual(log_record_processor._batch_processor._schedule_delay, 5)
-        self.assertEqual(log_record_processor._batch_processor._max_export_batch_size, 512)
-        self.assertEqual(log_record_processor._batch_processor._export_timeout_millis, 30000)
+        self.assertEqual(
+            log_record_processor._batch_processor._exporter, exporter
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._max_queue_size, 2048
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._schedule_delay, 5
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._max_export_batch_size, 512
+        )
+        self.assertEqual(
+            log_record_processor._batch_processor._export_timeout_millis, 30000
+        )
 
     def test_validation_negative_max_queue_size(self):
         exporter = InMemoryLogExporter()