Setting TextPropagator as default

Setting TextPropagator as default propagator for TEXT_MAP and HTTP_HEADERS

Author: ocelotl

examples/http/context_in_headers.py

@@ -29,6 +29,8 @@
 import opentracing
 import opentracing.ext.tags
 import lightstep
+from opentracing import Format
+from lightstep.b3_propagator import B3Propagator
 
 
 class RemoteHandler(BaseHTTPRequestHandler):
@@ -145,6 +147,12 @@ def lightstep_tracer_from_args():
 if __name__ == '__main__':
     with lightstep_tracer_from_args() as tracer:
         opentracing.tracer = tracer
+
+        opentracing.tracer.register_propagator(Format.TEXT_MAP, B3Propagator())
+        opentracing.tracer.register_propagator(
+            Format.HTTP_HEADERS, B3Propagator()
+        )
+
         global _exit_code
         _exit_code = 0
 

lightstep/tracer.py

@@ -9,7 +9,7 @@
 from __future__ import absolute_import
 
 from basictracer import BasicTracer
-from lightstep.b3_propagator import B3Propagator
+from basictracer.text_propagator import TextPropagator
 from opentracing import Format
 
 from lightstep.lightstep_binary_propagator import LightStepBinaryPropagator
@@ -73,8 +73,8 @@ class _LightstepTracer(BasicTracer):
     def __init__(self, enable_binary_format, recorder, scope_manager):
         """Initialize the LightStep Tracer, deferring to BasicTracer."""
         super(_LightstepTracer, self).__init__(recorder, scope_manager=scope_manager)
-        self.register_propagator(Format.TEXT_MAP, B3Propagator())
-        self.register_propagator(Format.HTTP_HEADERS, B3Propagator())
+        self.register_propagator(Format.TEXT_MAP, TextPropagator())
+        self.register_propagator(Format.HTTP_HEADERS, TextPropagator())
         if enable_binary_format:
             # We do this import lazily because protobuf versioning issues
             # can cause process-level failure at import time.

tests/b3_propagator_test.py

@@ -5,6 +5,7 @@
 
 from opentracing import Format
 from lightstep import Tracer
+from lightstep.b3_propagator import B3Propagator
 
 
 class B3PropagatorTest(TestCase):
@@ -13,6 +14,7 @@ def setUp(self):
             periodic_flush_seconds=0,
             collector_host="localhost"
         )
+        self._tracer.register_propagator(Format.HTTP_HEADERS, B3Propagator())
 
     def tracer(self):
         return self._tracer