Fix lint / precommit

Author: DylanRussell

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

@@ -54,7 +54,6 @@ class LogExportResult(enum.Enum):
     FAILURE = 1
 
 
-
 class LogExporter(abc.ABC):
     """Interface for exporting logs.
     Interface to be implemented by services that want to export logs received
@@ -79,6 +78,7 @@ def shutdown(self):
         Called when the SDK is shut down.
         """
 
+
 class ConsoleLogExporter(LogExporter):
     """Implementation of :class:`LogExporter` that prints log records to the
     console.

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

@@ -71,7 +71,7 @@ def __init__(
         # Deque is thread safe.
         self._queue = collections.deque([], max_queue_size)
         self._worker_thread = threading.Thread(
-            name="OtelBatch{}RecordProcessor".format(exporting),
+            name=f"OtelBatch{exporting}RecordProcessor",
             target=self.worker,
             daemon=True,
         )
@@ -105,7 +105,7 @@ def _at_fork_reinit(self):
         self._worker_awaken = threading.Event()
         self._queue.clear()
         self._worker_thread = threading.Thread(
-            name="OtelBatch{}RecordProcessor".format(self._exporting),
+            name=f"OtelBatch{self._exporting}RecordProcessor",
             target=self.worker,
             daemon=True,
         )
@@ -151,23 +151,19 @@ def _export(self, batch_strategy: BatchExportStrategy) -> None:
                     )
                 except Exception:  # pylint: disable=broad-exception-caught
                     self._logger.exception(
-                        "Exception while exporting {}.".format(self._exporting)
+                        "Exception while exporting %s.", self._exporting
                     )
                 detach(token)
 
     def emit(self, data: Union["LogRecord" | "Span"]) -> None:
         if self._shutdown:
-            self._logger.info(
-                "Shutdown called, ignoring {}.".format(self._exporting)
-            )
+            self._logger.info("Shutdown called, ignoring %s.", self._exporting)
             return
         if self._pid != os.getpid():
-            self.bsp_reset_once.do_once(self._at_fork_reinit)
+            self._bsp_reset_once.do_once(self._at_fork_reinit)
 
         if len(self._queue) == self._max_queue_size:
-            self._logger.warning(
-                "Queue full, dropping {}.".format(self._exporting)
-            )
+            self._logger.warning("Queue full, dropping %s.", self._exporting)
         self._queue.appendleft(data)
         if len(self._queue) >= self._max_export_batch_size:
             self._worker_awaken.set()

opentelemetry-sdk/tests/logs/test_export.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 
 # pylint: disable=protected-access
-import gc
 import logging
 import os
 import time
@@ -43,7 +42,6 @@
 )
 from opentelemetry.sdk.resources import Resource as SDKResource
 from opentelemetry.sdk.util.instrumentation import InstrumentationScope
-from opentelemetry.test.concurrency_test import ConcurrencyTestBase
 from opentelemetry.trace import TraceFlags
 from opentelemetry.trace.span import INVALID_SPAN_CONTEXT
 
@@ -467,6 +465,7 @@ def test_validation_negative_max_queue_size(self):
             max_export_batch_size=101,
         )
 
+
 class TestConsoleLogExporter(unittest.TestCase):
     def test_export(self):  # pylint: disable=no-self-use
         """Check that the console exporter prints log records."""