Fix lint

Author: rads-1996

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

@@ -935,13 +935,23 @@ def std_to_otel(levelno: int) -> SeverityNumber:
         return SeverityNumber.FATAL4
     return _STD_TO_OTEL[levelno]
 
-def is_less_than_min_severity(record: LogRecord, min_severity: SeverityNumber) -> bool:
+
+def is_less_than_min_severity(
+    record: LogRecord, min_severity: SeverityNumber
+) -> bool:
     if record.severity_number is not None:
-        if min_severity is not None and min_severity != SeverityNumber.UNSPECIFIED and record.severity_number.value < min_severity.value:
+        if (
+            min_severity is not None
+            and min_severity != SeverityNumber.UNSPECIFIED
+            and record.severity_number.value < min_severity.value
+        ):
             return True
     return False
 
-def should_drop_logs_for_trace_based(record: LogRecord, trace_state_enabled: bool) -> bool:
+
+def should_drop_logs_for_trace_based(
+    record: LogRecord, trace_state_enabled: bool
+) -> bool:
     if trace_state_enabled:
         if record.context is not None:
             span = get_current_span(record.context)

opentelemetry-sdk/tests/logs/test_logs.py

@@ -74,7 +74,9 @@ def test_get_logger(self):
         self.assertEqual(
             logger._instrumentation_scope.attributes, {"key": "value"}
         )
-        self.assertEqual(logger._min_severity_level, SeverityNumber.UNSPECIFIED)
+        self.assertEqual(
+            logger._min_severity_level, SeverityNumber.UNSPECIFIED
+        )
         self.assertFalse(logger._trace_based)
 
     @patch.dict("os.environ", {OTEL_SDK_DISABLED: "true"})
@@ -85,7 +87,9 @@ def test_get_logger_with_sdk_disabled(self):
 
     @patch.object(Resource, "create")
     def test_logger_provider_init(self, resource_patch):
-        logger_provider = LoggerProvider(min_severity_level=SeverityNumber.DEBUG4, trace_based=True)
+        logger_provider = LoggerProvider(
+            min_severity_level=SeverityNumber.DEBUG4, trace_based=True
+        )
         resource_patch.assert_called_once()
         self.assertIsNotNone(logger_provider._resource)
         self.assertTrue(
@@ -94,7 +98,9 @@ def test_logger_provider_init(self, resource_patch):
                 SynchronousMultiLogRecordProcessor,
             )
         )
-        self.assertEqual(logger_provider._min_severity_level, SeverityNumber.DEBUG4)
+        self.assertEqual(
+            logger_provider._min_severity_level, SeverityNumber.DEBUG4
+        )
         self.assertTrue(logger_provider._trace_based)
         self.assertIsNotNone(logger_provider._at_exit_handler)
 
@@ -205,7 +211,9 @@ def test_emit_logrecord_with_min_severity_filtering(self):
         log_record_processor_mock.on_emit.assert_called_once()
         log_data = log_record_processor_mock.on_emit.call_args.args[0]
         self.assertTrue(isinstance(log_data.log_record, LogRecord))
-        self.assertEqual(log_data.log_record.severity_number, SeverityNumber.ERROR)
+        self.assertEqual(
+            log_data.log_record.severity_number, SeverityNumber.ERROR
+        )
 
     def test_emit_logrecord_with_min_severity_unspecified(self):
         """Test that when min severity is UNSPECIFIED, all logs are emitted"""
@@ -233,7 +241,10 @@ def test_emit_logrecord_with_trace_based_filtering(self):
 
         mock_context = Mock()
 
-        with patch('opentelemetry.sdk._logs._internal.get_current_span', return_value=mock_span):
+        with patch(
+            "opentelemetry.sdk._logs._internal.get_current_span",
+            return_value=mock_span,
+        ):
             log_record = LogRecord(
                 observed_timestamp=0,
                 body="should be dropped",
@@ -267,7 +278,10 @@ def test_emit_logrecord_trace_filtering_disabled(self):
 
         mock_context = Mock()
 
-        with patch('opentelemetry.sdk._logs._internal.get_current_span', return_value=mock_span):
+        with patch(
+            "opentelemetry.sdk._logs._internal.get_current_span",
+            return_value=mock_span,
+        ):
             log_record = LogRecord(
                 observed_timestamp=0,
                 body="should be emitted when filtering disabled",
@@ -293,7 +307,10 @@ def test_emit_logrecord_trace_filtering_edge_cases(self):
 
         mock_context = Mock()
 
-        with patch('opentelemetry.sdk._logs._internal.get_current_span', return_value=mock_span):
+        with patch(
+            "opentelemetry.sdk._logs._internal.get_current_span",
+            return_value=mock_span,
+        ):
             log_record = LogRecord(
                 observed_timestamp=0,
                 body="invalid but sampled",
@@ -314,7 +331,10 @@ def test_emit_logrecord_trace_filtering_edge_cases(self):
         mock_span = Mock()
         mock_span.get_span_context.return_value = mock_span_context
 
-        with patch('opentelemetry.sdk._logs._internal.get_current_span', return_value=mock_span):
+        with patch(
+            "opentelemetry.sdk._logs._internal.get_current_span",
+            return_value=mock_span,
+        ):
             log_record = LogRecord(
                 observed_timestamp=0,
                 body="valid but not sampled",
@@ -341,7 +361,10 @@ def test_emit_both_min_severity_and_trace_based_filtering(self):
 
         mock_context = Mock()
 
-        with patch('opentelemetry.sdk._logs._internal.get_current_span', return_value=mock_span):
+        with patch(
+            "opentelemetry.sdk._logs._internal.get_current_span",
+            return_value=mock_span,
+        ):
             log_record_info = LogRecord(
                 observed_timestamp=0,
                 body="info log line",