style: Format document and fix lint violations.

Used ruff (vscode) to:
 - Black-compatible code formatting.
 - fix all auto-fixable violations, like unused imports.
 - isort-compatible import sorting.

Signed-off-by: Paulo Vital <[email protected]>

Author: pvital

instana/instrumentation/asyncio.py

@@ -3,19 +3,19 @@
 
 
 import wrapt
+from opentracing.scope_managers.constants import ACTIVE_ATTR
+from opentracing.scope_managers.contextvars import no_parent_scope
 
+from ..configurator import config
 from ..log import logger
 from ..singletons import async_tracer
-from ..configurator import config
-from opentracing.scope_managers.contextvars import no_parent_scope
-from opentracing.scope_managers.constants import ACTIVE_ATTR
 
 try:
     import asyncio
 
-    @wrapt.patch_function_wrapper('asyncio','ensure_future')
+    @wrapt.patch_function_wrapper("asyncio", "ensure_future")
     def ensure_future_with_instana(wrapped, instance, argv, kwargs):
-        if config['asyncio_task_context_propagation']['enabled'] is False:
+        if config["asyncio_task_context_propagation"]["enabled"] is False:
             with no_parent_scope():
                 return wrapped(*argv, **kwargs)
 
@@ -28,9 +28,10 @@ def ensure_future_with_instana(wrapped, instance, argv, kwargs):
         return task
 
     if hasattr(asyncio, "create_task"):
-        @wrapt.patch_function_wrapper('asyncio','create_task')
+
+        @wrapt.patch_function_wrapper("asyncio", "create_task")
         def create_task_with_instana(wrapped, instance, argv, kwargs):
-            if config['asyncio_task_context_propagation']['enabled'] is False:
+            if config["asyncio_task_context_propagation"]["enabled"] is False:
                 with no_parent_scope():
                     return wrapped(*argv, **kwargs)
 

instana/singletons.py

@@ -2,12 +2,12 @@
 # (c) Copyright Instana Inc. 2018
 
 import os
-import sys
+
 import opentracing
 
+from .autoprofile.profiler import Profiler
 from .log import logger
 from .tracer import InstanaTracer
-from .autoprofile.profiler import Profiler
 
 agent = None
 tracer = None
@@ -19,13 +19,17 @@
 aws_env = os.environ.get("AWS_EXECUTION_ENV", "")
 env_is_test = "INSTANA_TEST" in os.environ
 env_is_aws_fargate = aws_env == "AWS_ECS_FARGATE"
-env_is_aws_eks_fargate = (os.environ.get("INSTANA_TRACER_ENVIRONMENT") == "AWS_EKS_FARGATE")
+env_is_aws_eks_fargate = (
+    os.environ.get("INSTANA_TRACER_ENVIRONMENT") == "AWS_EKS_FARGATE"
+)
 env_is_aws_lambda = "AWS_Lambda_" in aws_env
 k_service = os.environ.get("K_SERVICE")
 k_configuration = os.environ.get("K_CONFIGURATION")
 k_revision = os.environ.get("K_REVISION")
 instana_endpoint_url = os.environ.get("INSTANA_ENDPOINT_URL")
-env_is_google_cloud_run = all((k_service, k_configuration, k_revision, instana_endpoint_url))
+env_is_google_cloud_run = all(
+    (k_service, k_configuration, k_revision, instana_endpoint_url)
+)
 
 if env_is_test:
     from .agent.test import TestAgent
@@ -52,7 +56,9 @@
     from instana.agent.google_cloud_run import GCRAgent
     from instana.recorder import StanRecorder
 
-    agent = GCRAgent(service=k_service, configuration=k_configuration, revision=k_revision)
+    agent = GCRAgent(
+        service=k_service, configuration=k_configuration, revision=k_revision
+    )
     span_recorder = StanRecorder(agent)
 elif env_is_aws_eks_fargate:
     from .agent.aws_eks_fargate import EKSFargateAgent
@@ -96,7 +102,10 @@ def set_agent(new_agent):
 
 try:
     from opentracing.scope_managers.contextvars import ContextVarsScopeManager
-    async_tracer = InstanaTracer(scope_manager=ContextVarsScopeManager(), recorder=span_recorder)
+
+    async_tracer = InstanaTracer(
+        scope_manager=ContextVarsScopeManager(), recorder=span_recorder
+    )
 except Exception:
     logger.debug("Error setting up async_tracer:", exc_info=True)
 
@@ -107,7 +116,10 @@ def set_agent(new_agent):
 def setup_tornado_tracer():
     global tornado_tracer
     from opentracing.scope_managers.tornado import TornadoScopeManager
-    tornado_tracer = InstanaTracer(scope_manager=TornadoScopeManager(), recorder=span_recorder)
+
+    tornado_tracer = InstanaTracer(
+        scope_manager=TornadoScopeManager(), recorder=span_recorder
+    )
 
 
 # Set ourselves as the tracer.