run precommit hooks

Author: bisgaard-itis

instrumentation/opentelemetry-instrumentation-aiohttp-server/src/opentelemetry/instrumentation/aiohttp_server/__init__.py

@@ -228,24 +228,32 @@ def keys(self, carrier: Dict) -> List:
 
 getter = AiohttpGetter()
 
-def create_aiohttp_middleware(tracer_provider: trace.TracerProvider | None = None):
-    _tracer = tracer_provider.get_tracer(
-        __name__, __version__
-    ) if tracer_provider else tracer
+
+def create_aiohttp_middleware(
+    tracer_provider: trace.TracerProvider | None = None,
+):
+    _tracer = (
+        tracer_provider.get_tracer(__name__, __version__)
+        if tracer_provider
+        else tracer
+    )
 
     @web.middleware
     async def _middleware(request, handler):
         """Middleware for aiohttp implementing tracing logic"""
-        if not is_http_instrumentation_enabled() or _excluded_urls.url_disabled(
-            request.url.path
+        if (
+            not is_http_instrumentation_enabled()
+            or _excluded_urls.url_disabled(request.url.path)
         ):
             return await handler(request)
 
         span_name, additional_attributes = get_default_span_details(request)
 
         req_attrs = collect_request_attributes(request)
         duration_attrs = _parse_duration_attrs(req_attrs)
-        active_requests_count_attrs = _parse_active_request_count_attrs(req_attrs)
+        active_requests_count_attrs = _parse_active_request_count_attrs(
+            req_attrs
+        )
 
         duration_histogram = meter.create_histogram(
             name=MetricInstruments.HTTP_SERVER_DURATION,
@@ -280,13 +288,18 @@ async def _middleware(request, handler):
                 duration_histogram.record(duration, duration_attrs)
                 active_requests_counter.add(-1, active_requests_count_attrs)
             return resp
+
     return _middleware
 
-middleware = create_aiohttp_middleware() # for backwards compatibility
 
+middleware = create_aiohttp_middleware()  # for backwards compatibility
 
-def create_instrumented_application(tracer_provider: trace.TracerProvider | None = None):
+
+def create_instrumented_application(
+    tracer_provider: trace.TracerProvider | None = None,
+):
     _middleware = create_aiohttp_middleware(tracer_provider=tracer_provider)
+
     class _InstrumentedApplication(web.Application):
         """Insert tracing middleware"""
 
@@ -298,6 +311,7 @@ def __init__(self, *args, **kwargs):
 
     return _InstrumentedApplication
 
+
 class AioHttpServerInstrumentor(BaseInstrumentor):
     # pylint: disable=protected-access,attribute-defined-outside-init
     """An instrumentor for aiohttp.web.Application

instrumentation/opentelemetry-instrumentation-aiohttp-server/tests/test_aiohttp_server_integration.py

@@ -24,6 +24,7 @@
     AioHttpServerInstrumentor,
 )
 from opentelemetry.instrumentation.utils import suppress_http_instrumentation
+from opentelemetry.sdk.trace.sampling import ParentBased, TraceIdRatioBased
 from opentelemetry.semconv._incubating.attributes.http_attributes import (
     HTTP_METHOD,
     HTTP_STATUS_CODE,
@@ -32,7 +33,7 @@
 from opentelemetry.test.globals_test import reset_trace_globals
 from opentelemetry.test.test_base import TestBase
 from opentelemetry.util._importlib_metadata import entry_points
-from opentelemetry.sdk.trace.sampling import ParentBased, TraceIdRatioBased
+
 
 class HTTPMethod(Enum):
     """HTTP methods and descriptions"""
@@ -197,10 +198,14 @@ async def handler(request):
     memory_exporter.clear()
 
 
-
 @pytest.mark.asyncio
 @pytest.mark.parametrize(
-    "tracer", [TestBase().create_tracer_provider(sampler=ParentBased(TraceIdRatioBased(0.05)))]
+    "tracer",
+    [
+        TestBase().create_tracer_provider(
+            sampler=ParentBased(TraceIdRatioBased(0.05))
+        )
+    ],
 )
 async def test_non_global_tracer_provider(
     tracer,
@@ -225,4 +230,8 @@ async def test_non_global_tracer_provider(
         for span in memory_exporter.get_finished_spans()
         if span.context is not None
     }
-    assert 0.5 * n_expected_trace_ids <= len(trace_ids) <= 1.5 * n_expected_trace_ids
+    assert (
+        0.5 * n_expected_trace_ids
+        <= len(trace_ids)
+        <= 1.5 * n_expected_trace_ids
+    )