chore: use get_tracer() for all tracer access

Signed-off-by: Cagri Yonca <[email protected]>

Author: CagriYonca

src/instana/instrumentation/aio_pika.py

@@ -1,7 +1,7 @@
 # (c) Copyright IBM Corp. 2025
 
 try:
-    import aio_pika
+    import aio_pika  # noqa: F401
     import wrapt
     from typing import (
         TYPE_CHECKING,
@@ -16,7 +16,7 @@
     from instana.log import logger
     from instana.propagators.format import Format
     from instana.util.traceutils import get_tracer_tuple, tracing_is_off
-    from instana.singletons import tracer
+    from instana.singletons import get_tracer
 
     if TYPE_CHECKING:
         from instana.span.span import InstanaSpan
@@ -54,10 +54,8 @@ def _bind_args(
             **kwargs: object,
         ) -> Tuple[object, ...]:
             return (message, routing_key, args, kwargs)
-        
-        (message, routing_key, args, kwargs) = _bind_args(
-            *args, **kwargs
-        )
+
+        (message, routing_key, args, kwargs) = _bind_args(*args, **kwargs)
 
         with tracer.start_as_current_span(
             "rabbitmq", span_context=parent_context
@@ -102,6 +100,7 @@ async def callback_wrapper(
             kwargs: Dict[str, Any],
         ) -> Callable[[Type["AbstractMessage"]], Any]:
             message = args[0]
+            tracer = get_tracer()
             parent_context = tracer.extract(
                 Format.HTTP_HEADERS, message.headers, disable_w3c_trace_context=True
             )

src/instana/instrumentation/aiohttp/server.py

@@ -9,7 +9,7 @@
 
 from instana.log import logger
 from instana.propagators.format import Format
-from instana.singletons import agent, tracer
+from instana.singletons import agent, get_tracer
 from instana.util.secrets import strip_secrets_from_query
 from instana.util.traceutils import extract_custom_headers
 
@@ -29,6 +29,7 @@ async def stan_middleware(
         handler: Callable[..., object],
     ) -> Awaitable["aiohttp.web.Response"]:
         try:
+            tracer = get_tracer()
             span_context = tracer.extract(Format.HTTP_HEADERS, request.headers)
             span: "InstanaSpan" = tracer.start_span(
                 "aiohttp-server", span_context=span_context

src/instana/instrumentation/asgi.py

@@ -8,11 +8,10 @@
 from typing import TYPE_CHECKING, Any, Awaitable, Callable, Dict
 
 from opentelemetry.semconv.trace import SpanAttributes
-from opentelemetry.trace import SpanKind
 
 from instana.log import logger
 from instana.propagators.format import Format
-from instana.singletons import agent, tracer
+from instana.singletons import agent, get_tracer
 from instana.util.secrets import strip_secrets_from_query
 from instana.util.traceutils import extract_custom_headers
 
@@ -66,6 +65,7 @@ async def __call__(
         send: Callable[[Dict[str, Any]], Awaitable[None]],
     ) -> None:
         request_context = None
+        tracer = get_tracer()
 
         if scope["type"] not in ("http", "websocket"):
             return await self.app(scope, receive, send)
@@ -104,11 +104,14 @@ async def send_wrapper(response: Dict[str, Any]) -> Awaitable[None]:
                     if status_code:
                         if 500 <= int(status_code):
                             current_span.mark_as_errored()
-                        current_span.set_attribute(SpanAttributes.HTTP_STATUS_CODE, status_code)
+                        current_span.set_attribute(
+                            SpanAttributes.HTTP_STATUS_CODE, status_code
+                        )
 
                     headers = response.get("headers")
                     if headers:
                         extract_custom_headers(current_span, headers)
+                        tracer = get_tracer()
                         tracer.inject(current_span.context, Format.BINARY, headers)
                 except Exception:
                     logger.debug("ASGI send_wrapper error: ", exc_info=True)

src/instana/instrumentation/aws/boto3.py

@@ -19,7 +19,7 @@
 
     from instana.log import logger
     from instana.propagators.format import Format
-    from instana.singletons import tracer
+    from instana.singletons import get_tracer
     from instana.span.span import get_current_span
     from instana.util.traceutils import (
         extract_custom_headers,
@@ -34,6 +34,7 @@ def lambda_inject_context(payload: Dict[str, Any], span: "InstanaSpan") -> None:
         https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/lambda.html#Lambda.Client.invoke
         """
         try:
+            tracer = get_tracer()
             invoke_payload = payload.get("Payload", {})
 
             if not isinstance(invoke_payload, dict):

src/instana/instrumentation/aws/dynamodb.py

@@ -6,7 +6,7 @@
     from botocore.client import BaseClient
 
 from instana.log import logger
-from instana.singletons import tracer
+from instana.singletons import get_tracer
 from instana.span_context import SpanContext
 
 
@@ -17,6 +17,7 @@ def create_dynamodb_span(
     kwargs: Dict[str, Any],
     parent_context: SpanContext,
 ) -> None:
+    tracer = get_tracer()
     with tracer.start_as_current_span("dynamodb", span_context=parent_context) as span:
         try:
             span.set_attribute("dynamodb.op", args[0])

src/instana/instrumentation/aws/s3.py

@@ -11,7 +11,7 @@
     import wrapt
 
     from instana.log import logger
-    from instana.singletons import tracer
+    from instana.singletons import get_tracer
     from instana.util.traceutils import (
         get_tracer_tuple,
         tracing_is_off,
@@ -31,6 +31,7 @@ def create_s3_span(
         kwargs: Dict[str, Any],
         parent_context: SpanContext,
     ) -> None:
+        tracer = get_tracer()
         with tracer.start_as_current_span("s3", span_context=parent_context) as span:
             try:
                 span.set_attribute("s3.op", args[0])
@@ -66,15 +67,17 @@ def collect_s3_injected_attributes(
                         span.set_attribute("s3.bucket", args[1])
             except Exception:
                 logger.debug(
-                    f"collect_s3_injected_attributes collect error: {wrapped.__name__}", exc_info=True
+                    f"collect_s3_injected_attributes collect error: {wrapped.__name__}",
+                    exc_info=True,
                 )
 
             try:
                 return wrapped(*args, **kwargs)
             except Exception as exc:
                 span.record_exception(exc)
                 logger.debug(
-                    f"collect_s3_injected_attributes error: {wrapped.__name__}", exc_info=True
+                    f"collect_s3_injected_attributes error: {wrapped.__name__}",
+                    exc_info=True,
                 )
                 raise
 

src/instana/instrumentation/celery.py

@@ -2,20 +2,20 @@
 # (c) Copyright Instana Inc. 2020
 
 
-import contextvars
-from typing import Any, Dict, Tuple
-from instana.log import logger
-from instana.propagators.format import Format
-from instana.singletons import tracer
-from instana.span.span import InstanaSpan
-from instana.util.traceutils import get_tracer_tuple
-from opentelemetry import trace, context
-
 try:
-    import celery
+    import celery  # noqa: F401
+    import contextvars
+    from typing import Any, Dict, Tuple
+    from urllib import parse
+
     from celery import registry, signals
+    from opentelemetry import context, trace
 
-    from urllib import parse
+    from instana.log import logger
+    from instana.propagators.format import Format
+    from instana.singletons import get_tracer
+    from instana.span.span import InstanaSpan
+    from instana.util.traceutils import get_tracer_tuple
 
     client_token: Dict[str, Any] = {}
     worker_token: Dict[str, Any] = {}
@@ -67,6 +67,7 @@ def task_prerun(
     ) -> None:
         try:
             ctx = None
+            tracer = get_tracer()
 
             task = kwargs.get("sender", None)
             task_id = kwargs.get("task_id", None)

src/instana/instrumentation/django/middleware.py

@@ -11,7 +11,7 @@
     from typing import TYPE_CHECKING, Dict, Any, Callable, Optional, List, Tuple, Type
 
     from instana.log import logger
-    from instana.singletons import agent, tracer
+    from instana.singletons import agent, get_tracer
     from instana.util.secrets import strip_secrets_from_query
     from instana.util.traceutils import extract_custom_headers
     from instana.propagators.format import Format
@@ -55,6 +55,7 @@ def __init__(
 
         def process_request(self, request: Type["HttpRequest"]) -> None:
             try:
+                tracer = get_tracer()
                 env = request.META
 
                 span_context = tracer.extract(Format.HTTP_HEADERS, env)
@@ -81,7 +82,9 @@ def process_request(self, request: Type["HttpRequest"]) -> None:
                     )
                     request.span.set_attribute("http.params", scrubbed_params)
                 if "HTTP_HOST" in env:
-                    request.span.set_attribute(SpanAttributes.HTTP_HOST, env["HTTP_HOST"])
+                    request.span.set_attribute(
+                        SpanAttributes.HTTP_HOST, env["HTTP_HOST"]
+                    )
             except Exception:
                 logger.debug("Django middleware @ process_request", exc_info=True)
 
@@ -118,6 +121,7 @@ def process_response(
                         extract_custom_headers(
                             request.span, response.headers, format=False
                         )
+                    tracer = get_tracer()
                     tracer.inject(request.span.context, Format.HTTP_HEADERS, response)
             except Exception:
                 logger.debug("Instana middleware @ process_response", exc_info=True)

src/instana/instrumentation/google/cloud/pubsub.py

@@ -8,7 +8,7 @@
 
 from instana.log import logger
 from instana.propagators.format import Format
-from instana.singletons import tracer
+from instana.singletons import get_tracer
 from instana.util.traceutils import get_tracer_tuple, tracing_is_off
 
 if TYPE_CHECKING:
@@ -98,6 +98,7 @@ def subscribe_with_instana(
 
         def callback_with_instana(message):
             if message.attributes:
+                tracer = get_tracer()
                 parent_context = tracer.extract(
                     Format.TEXT_MAP, message.attributes, disable_w3c_trace_context=True
                 )

src/instana/instrumentation/pika.py

@@ -20,7 +20,7 @@
 
     from instana.log import logger
     from instana.propagators.format import Format
-    from instana.singletons import tracer
+    from instana.singletons import get_tracer
     from instana.util.traceutils import get_tracer_tuple, tracing_is_off
 
     if TYPE_CHECKING:
@@ -142,6 +142,7 @@ def _cb_wrapper(
             properties: pika.BasicProperties,
             body: str,
         ) -> None:
+            tracer = get_tracer()
             parent_context = tracer.extract(
                 Format.HTTP_HEADERS, properties.headers, disable_w3c_trace_context=True
             )
@@ -189,6 +190,7 @@ def _cb_wrapper(
             properties: pika.BasicProperties,
             body: str,
         ) -> None:
+            tracer = get_tracer()
             parent_context = tracer.extract(
                 Format.HTTP_HEADERS, properties.headers, disable_w3c_trace_context=True
             )
@@ -230,6 +232,7 @@ def _bind_args(
         (queue, args, kwargs) = _bind_args(*args, **kwargs)
 
         def _consume(gen: Iterator[object]) -> object:
+            tracer = get_tracer()
             for yielded in gen:
                 # Bypass the delivery created due to inactivity timeout
                 if not yielded or not any(yielded):