@@ -228,6 +228,7 @@ use once_cell::sync::Lazy;
228
228
229
229
/// A tokio runtime for the sync tests, permitting the use of tracing. This is
230
230
/// never shutdown, instead it is just dropped at end of process.
231
+ #[ cfg( feature = "otel" ) ]
231
232
static TRACE_RUNTIME : Lazy < tokio:: runtime:: Runtime > =
232
233
Lazy :: new ( || tokio:: runtime:: Runtime :: new ( ) . unwrap ( ) ) ;
233
234
@@ -239,16 +240,13 @@ type Tracer = ();
239
240
240
241
/// A tracer for the tests.
241
242
pub ( crate ) static TRACER : Lazy < Tracer > = Lazy :: new ( || {
242
- use tracing_subscriber:: Registry ;
243
-
244
243
#[ cfg( feature = "otel" ) ]
245
244
{
246
- use crate :: cli:: log:: { telemetry , telemetry_default_tracer} ;
245
+ use crate :: cli:: log:: telemetry_default_tracer;
247
246
248
247
use opentelemetry:: global;
249
248
use opentelemetry_sdk:: propagation:: TraceContextPropagator ;
250
249
use tokio:: runtime:: Handle ;
251
- use tracing_subscriber:: layer:: SubscriberExt as _;
252
250
253
251
// Use the current runtime, or the sync test runtime otherwise.
254
252
let handle = match Handle :: try_current ( ) {
@@ -259,16 +257,7 @@ pub(crate) static TRACER: Lazy<Tracer> = Lazy::new(|| {
259
257
let _guard = handle. enter ( ) ;
260
258
261
259
global:: set_text_map_propagator ( TraceContextPropagator :: new ( ) ) ;
262
- let tracer = telemetry_default_tracer ( ) . unwrap ( ) ;
263
- let telemetry = telemetry ( tracer. clone ( ) ) ;
264
- let subscriber = Registry :: default ( ) . with ( telemetry) ;
265
- tracing:: subscriber:: set_global_default ( subscriber) . unwrap ( ) ;
266
- tracer
267
- }
268
- #[ cfg( not( feature = "otel" ) ) ]
269
- {
270
- let subscriber = Registry :: default ( ) ;
271
- tracing:: subscriber:: set_global_default ( subscriber) . unwrap ( ) ;
260
+ telemetry_default_tracer ( ) . unwrap ( )
272
261
}
273
262
} ) ;
274
263
0 commit comments