pre-commit

Author: znd4

examples/handlers/opentelemetry_structlog/app.py

@@ -1,16 +1,17 @@
+import sys
 from random import randint
-from flask import Flask, request
+
 import structlog
-import sys
+from flask import Flask, request
 
 sys.path.insert(0, "../../..")
 from handlers.opentelemetry_structlog.src.exporter import StructlogHandler
+from opentelemetry._logs import set_logger_provider
 from opentelemetry.exporter.otlp.proto.grpc._log_exporter import (
     OTLPLogExporter,
 )
 from opentelemetry.sdk._logs import LoggerProvider
 from opentelemetry.sdk.resources import Resource
-from opentelemetry._logs import set_logger_provider
 
 logger_provider = LoggerProvider(
     resource=Resource.create(
@@ -43,7 +44,10 @@ def roll_dice():
     result = str(roll())
     if player:
         structlog_logger.warning(
-            "Player %s is rolling the dice: %s", player, result, level="warning"
+            "Player %s is rolling the dice: %s",
+            player,
+            result,
+            level="warning",
         )
     else:
         structlog_logger.warning(

handlers/opentelemetry_structlog/src/exporter.py

@@ -5,15 +5,19 @@
 from typing import Dict
 
 import structlog
+from structlog._frames import _format_exception
+from structlog._log_levels import NAME_TO_LEVEL
+from structlog.processors import _figure_out_exc_info
+
 from opentelemetry._logs import std_to_otel
 from opentelemetry.sdk._logs._internal import LoggerProvider, LogRecord
-from opentelemetry.sdk._logs._internal.export import BatchLogRecordProcessor, LogExporter
+from opentelemetry.sdk._logs._internal.export import (
+    BatchLogRecordProcessor,
+    LogExporter,
+)
 from opentelemetry.sdk.resources import Resource
 from opentelemetry.semconv.trace import SpanAttributes
 from opentelemetry.trace import get_current_span
-from structlog._frames import _format_exception
-from structlog._log_levels import NAME_TO_LEVEL
-from structlog.processors import _figure_out_exc_info
 
 _EXCLUDE_ATTRS = {"exception", "timestamp"}
 
@@ -112,7 +116,11 @@ def _translate(
             body=event_dict["event"],
             resource=self._logger.resource,
             attributes={
-                **{k: v for k, v in event_dict.items() if k not in _EXCLUDE_ATTRS},
+                **{
+                    k: v
+                    for k, v in event_dict.items()
+                    if k not in _EXCLUDE_ATTRS
+                },
                 **extra_attrs,
             },
         )
@@ -122,7 +130,9 @@ def _parse_timestamp(event_dict: structlog.typing.EventDict) -> int:
         return int(event_dict["timestamp"].timestamp() * 1e9)
 
     @staticmethod
-    def _parse_exception(event_dict: structlog.typing.EventDict) -> Dict[str, str]:
+    def _parse_exception(
+        event_dict: structlog.typing.EventDict,
+    ) -> Dict[str, str]:
         # taken from: https://github.com/open-telemetry/opentelemetry-python/blob/c4d17e9f14f3cafb6757b96eefabdc7ed4891306/opentelemetry-sdk/src/opentelemetry/sdk/_logs/_internal/__init__.py#L458-L475
         attributes: Dict[str, str] = {}
         exception = event_dict.get("exception", None)