chore: use get_tracer() for all tracer access

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

Author: CagriYonca

example/carry_context.py

@@ -11,10 +11,13 @@
 import uvloop
 import aiohttp
 
-from instana.singletons import tracer, async_tracer
+from instana.singletons import get_tracer
 
 uvloop.install()
 
+tracer = get_tracer()
+
+
 async def launch_async_calls(parent_span):
     """
     Method to launch a series (1 currently) of asynchronous http calls
@@ -24,24 +27,24 @@ async def launch_async_calls(parent_span):
 
     # Now that we are inside of the event loop, first thing to do is to initialize
     # the tracing context using <parent_span> _and_ the asynchronous tracer <async_tracer>
-    with async_tracer.start_active_span('launch_async_calls', child_of=parent_span):
+    with async_tracer.start_active_span("launch_async_calls", child_of=parent_span):  # noqa: F821
         async with aiohttp.ClientSession() as session:
             session.get("http://127.0.0.1/api/v2/endpoint/1")
             session.get("http://127.0.0.1/api/v2/endpoint/2")
             session.get("http://127.0.0.1/api/v2/endpoint/3")
 
+
 #
 # Synchronous application code such as from inside a Django or Flask handler
 #
 
 # Start an ENTRY span in our synchronous execution scope
 with tracer.start_active_span("launch_uvloop") as sync_scope:
-    sync_scope.span.set_tag('span.kind', 'entry')
+    sync_scope.span.set_tag("span.kind", "entry")
 
     # You can also retrieve the currently active span with:
     # tracer.active_span
 
     # Launch our requests asynchronously
     # Enter the event loop and pass in the parent tracing context (sync_scope) manually
     asyncio.run(launch_async_calls(sync_scope.span))
-

src/instana/instrumentation/aio_pika.py

@@ -1,7 +1,6 @@
 # (c) Copyright IBM Corp. 2025
 
 try:
-    import aio_pika
     import wrapt
     from typing import (
         TYPE_CHECKING,
@@ -16,7 +15,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 +53,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 +99,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,19 @@
 # (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 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 +66,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/flask/common.py

@@ -10,7 +10,7 @@
 from opentelemetry.semconv.trace import SpanAttributes
 
 from instana.log import logger
-from instana.singletons import tracer
+from instana.singletons import get_tracer
 from instana.propagators.format import Format
 
 
@@ -19,7 +19,8 @@
     from flask.typing import ResponseReturnValue
     from jinja2.environment import Template
 
-@wrapt.patch_function_wrapper('flask', 'templating._render')
+
+@wrapt.patch_function_wrapper("flask", "templating._render")
 def render_with_instana(
     wrapped: Callable[..., str],
     instance: object,
@@ -32,6 +33,7 @@ def render_with_instana(
 
     parent_span = flask.g.span
     parent_context = parent_span.get_span_context()
+    tracer = get_tracer()
 
     with tracer.start_as_current_span("render", span_context=parent_context) as span:
         try:
@@ -50,7 +52,7 @@ def render_with_instana(
             raise
 
 
-@wrapt.patch_function_wrapper('flask', 'Flask.handle_user_exception')
+@wrapt.patch_function_wrapper("flask", "Flask.handle_user_exception")
 def handle_user_exception_with_instana(
     wrapped: Callable[..., Union["HTTPException", "ResponseReturnValue"]],
     instance: flask.app.Flask,
@@ -70,7 +72,7 @@ def handle_user_exception_with_instana(
                 if isinstance(response, tuple):
                     status_code = response[1]
                 else:
-                    if hasattr(response, 'code'):
+                    if hasattr(response, "code"):
                         status_code = response.code
                     else:
                         status_code = response.status_code
@@ -80,12 +82,13 @@ def handle_user_exception_with_instana(
 
                 span.set_attribute(SpanAttributes.HTTP_STATUS_CODE, int(status_code))
 
-                if hasattr(response, 'headers'):
+                if hasattr(response, "headers"):
+                    tracer = get_tracer()
                     tracer.inject(span.context, Format.HTTP_HEADERS, response.headers)
             if span and span.is_recording():
                 span.end()
             flask.g.span = None
-    except:
+    except Exception:
         logger.debug("handle_user_exception_with_instana:", exc_info=True)
 
     return response