@@ -105,12 +105,13 @@ def setup_opentelemetry(app):
105105 from opentelemetry .sdk .resources import SERVICE_INSTANCE_ID , SERVICE_NAME , Resource
106106
107107 # No permission for trace.googleapis.com
108- # from opentelemetry import trace
108+ from opentelemetry import trace
109109 # from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
110- # from opentelemetry.sdk.trace import TracerProvider
111- # from opentelemetry.sdk.trace.export import BatchSpanProcessor
112-
113- from opentelemetry import metrics
110+ from opentelemetry .sdk .trace import TracerProvider
111+ from opentelemetry .sdk .trace .export import BatchSpanProcessor
112+ from opentelemetry .propagate import set_global_textmap
113+ from opentelemetry .propagators .cloud_trace_propagator import CloudTraceFormatPropagator
114+ from opentelemetry .exporter .cloud_trace import CloudTraceSpanExporter
114115 from opentelemetry .exporter .otlp .proto .http .metric_exporter import OTLPMetricExporter
115116 from opentelemetry .sdk .metrics import MeterProvider
116117 from opentelemetry .sdk .metrics .export import PeriodicExportingMetricReader
@@ -121,16 +122,12 @@ def setup_opentelemetry(app):
121122 SERVICE_INSTANCE_ID : f"worker-{ os .getpid ()} " ,
122123 })
123124
124- # tracer_provider = TracerProvider(resource=resource)
125- # processor = BatchSpanProcessor(OTLPSpanExporter())
126- # tracer_provider.add_span_processor(processor)
127- # trace.set_tracer_provider(tracer_provider)
125+ provider = TracerProvider (resource = resource )
126+ processor = BatchSpanProcessor (CloudTraceSpanExporter ())
127+ provider .add_span_processor (processor )
128128
129- reader = PeriodicExportingMetricReader (
130- OTLPMetricExporter ()
131- )
132- meter_provider = MeterProvider (metric_readers = [reader ], resource = resource )
133- metrics .set_meter_provider (meter_provider )
129+ trace .set_tracer_provider (provider )
130+ set_global_textmap (CloudTraceFormatPropagator ())
134131
135132 from opentelemetry .instrumentation .flask import FlaskInstrumentor
136133 FlaskInstrumentor ().instrument_app (app )
0 commit comments