chore(pin): deprecate multi tracer support

ddtrace/contrib/grpc/__init__.py

@@ -45,13 +45,12 @@
 ``Pin`` API::
 
     import grpc
-    from ddtrace import Pin, patch, Tracer
+    from ddtrace import Pin, patch
 
     patch(grpc=True)
-    custom_tracer = Tracer()
 
     # override the pin on the client
-    Pin.override(grpc.Channel, service='mygrpc', tracer=custom_tracer)
+    Pin.override(grpc.Channel, service='mygrpc')
     with grpc.insecure_channel('localhost:50051') as channel:
         # create stubs and send requests
         pass
@@ -61,13 +60,12 @@
     import grpc
     from grpc.framework.foundation import logging_pool
 
-    from ddtrace import Pin, patch, Tracer
+    from ddtrace import Pin, patch
 
     patch(grpc=True)
-    custom_tracer = Tracer()
 
     # override the pin on the server
-    Pin.override(grpc.Server, service='mygrpc', tracer=custom_tracer)
+    Pin.override(grpc.Server, service='mygrpc')
     server = grpc.server(logging_pool.pool(2))
     server.add_insecure_port('localhost:50051')
     add_MyServicer_to_server(MyServicer(), server)

ddtrace/contrib/internal/django/patch.py

@@ -17,6 +17,7 @@
 import wrapt
 from wrapt.importer import when_imported
 
+import ddtrace
 from ddtrace import Pin
 from ddtrace import config
 from ddtrace.appsec._utils import _UserInfoRetriever
@@ -147,7 +148,12 @@ def cursor(django, pin, func, instance, args, kwargs):
         tags = {"django.db.vendor": vendor, "django.db.alias": alias}
         tags.update(getattr(conn, "_datadog_tags", {}))
 
-        pin = Pin(service, tags=tags, tracer=pin.tracer)
+        # Calling ddtrace.pin.Pin(...) with the `tracer` argument generates a deprecation warning.
+        # Remove this if statement when the `tracer` argument is removed
+        if pin.tracer is ddtrace.tracer:
+            pin = Pin(service, tags=tags)
+        else:
+            pin = Pin(service, tags=tags, tracer=pin.tracer)
 
         cursor = func(*args, **kwargs)
 

ddtrace/contrib/internal/mongoengine/trace.py

@@ -23,12 +23,17 @@ class WrappedConnect(wrapt.ObjectProxy):
 
     def __init__(self, connect):
         super(WrappedConnect, self).__init__(connect)
-        ddtrace.Pin(_SERVICE, tracer=ddtrace.tracer).onto(self)
+        ddtrace.Pin(_SERVICE).onto(self)
 
     def __call__(self, *args, **kwargs):
         client = self.__wrapped__(*args, **kwargs)
         pin = ddtrace.Pin.get_from(self)
         if pin:
-            ddtrace.Pin(service=pin.service, tracer=pin.tracer).onto(client)
+            # Calling ddtrace.pin.Pin(...) with the `tracer` argument generates a deprecation warning.
+            # Remove this if statement when the `tracer` argument is removed
+            if pin.tracer is ddtrace.tracer:
+                ddtrace.Pin(service=pin.service).onto(client)
+            else:
+                ddtrace.Pin(service=pin.service, tracer=pin.tracer).onto(client)
 
         return client

ddtrace/contrib/internal/pylibmc/client.py

@@ -51,7 +51,12 @@ def __init__(self, client=None, service=memcached.SERVICE, tracer=None, *args, *
         super(TracedClient, self).__init__(client)
 
         schematized_service = schematize_service_name(service)
-        pin = ddtrace.Pin(service=schematized_service, tracer=tracer)
+        # Calling ddtrace.pin.Pin(...) with the `tracer` argument generates a deprecation warning.
+        # Remove this if statement when the `tracer` argument is removed
+        if tracer is ddtrace.tracer:
+            pin = ddtrace.Pin(service=schematized_service)
+        else:
+            pin = ddtrace.Pin(service=schematized_service, tracer=tracer)
         pin.onto(self)
 
         # attempt to collect the pool of urls this client talks to

ddtrace/contrib/internal/sqlalchemy/engine.py

@@ -67,7 +67,12 @@ def __init__(self, tracer, service, engine):
         self.name = schematize_database_operation("%s.query" % self.vendor, database_provider=self.vendor)
 
         # attach the PIN
-        Pin(tracer=tracer, service=self.service).onto(engine)
+        # Calling ddtrace.pin.Pin(...) with the `tracer` argument generates a deprecation warning.
+        # Remove this if statement when the `tracer` argument is removed
+        if self.tracer is ddtrace.tracer:
+            Pin(service=self.service).onto(engine)
+        else:
+            Pin(tracer=tracer, service=self.service).onto(engine)
 
         listen(engine, "before_cursor_execute", self._before_cur_exec)
         listen(engine, "after_cursor_execute", self._after_cur_exec)

ddtrace/contrib/internal/tornado/application.py

@@ -55,4 +55,4 @@ def tracer_config(__init__, app, args, kwargs):
         tracer.set_tags(tags)
 
     # configure the PIN object for template rendering
-    ddtrace.Pin(service=service, tracer=tracer).onto(template)
+    ddtrace.Pin(service=service).onto(template)

ddtrace/contrib/vertica/__init__.py

@@ -35,8 +35,8 @@
     custom_tracer = Tracer()
     conn = vertica_python.connect(**YOUR_VERTICA_CONFIG)
 
-    # override the service and tracer to be used
-    Pin.override(conn, service='myverticaservice', tracer=custom_tracer)
+    # override the service
+    Pin.override(conn, service='myverticaservice')
 """
 
 

ddtrace/pin.py

@@ -6,6 +6,7 @@
 import wrapt
 
 import ddtrace
+from ddtrace.vendor.debtcollector import deprecate
 
 from .internal.logger import get_logger
 
@@ -41,6 +42,12 @@ def __init__(
         _config=None,  # type: Optional[Dict[str, Any]]
     ):
         # type: (...) -> None
+        if tracer is not None:
+            deprecate(
+                "Initializing ddtrace.Pin with `tracer` argument is deprecated",
+                message="All Pin instances should use the global tracer instance",
+                removal_version="3.0.0",
+            )
         tracer = tracer or ddtrace.tracer
         self.tags = tags
         self.tracer = tracer
@@ -132,6 +139,12 @@ def override(
             >>> # Override a pin for a specific connection
             >>> Pin.override(conn, service='user-db')
         """
+        if tracer is not None:
+            deprecate(
+                "Calling ddtrace.Pin.override(...) with the `tracer` argument is deprecated",
+                message="All Pin instances should use the global tracer instance",
+                removal_version="3.0.0",
+            )
         if not obj:
             return
 
@@ -193,6 +206,13 @@ def clone(
         if not tags and self.tags:
             tags = self.tags.copy()
 
+        if tracer is not None:
+            deprecate(
+                "Initializing ddtrace.Pin with `tracer` argument is deprecated",
+                message="All Pin instances should use the global tracer instance",
+                removal_version="3.0.0",
+            )
+
         # we use a copy instead of a deepcopy because we expect configurations
         # to have only a root level dictionary without nested objects. Using
         # deepcopy introduces a big overhead:

releasenotes/notes/remove-multi-tracer-support-from-pin-f2f20ca3fa731929.yaml

@@ -0,0 +1,4 @@
+---
+deprecations:
+  - |
+    tracer: Deprecates the ability to use multiple tracer instances with ddtrace.Pin. In v3.0.0 pin objects will only use the global tracer.