@@ -1136,45 +1136,3 @@ impl std::io::Write for CapturingHandle {
11361136 Ok ( ( ) )
11371137 }
11381138}
1139-
1140- #[ tokio:: test]
1141- async fn otel_errors_logged_as_errors ( ) {
1142- // Set up tracing subscriber to capture ERROR logs
1143- let logs = Arc :: new ( Mutex :: new ( Vec :: new ( ) ) ) ;
1144- let writer = CapturingWriter { buf : logs. clone ( ) } ;
1145- let subscriber = tracing_subscriber:: fmt ( ) . with_writer ( writer) . finish ( ) ;
1146- let _guard = tracing:: subscriber:: set_default ( subscriber) ;
1147-
1148- let opts = OtelCollectorOptionsBuilder :: default ( )
1149- . url ( "https://localhost:12345/v1/metrics" . parse ( ) . unwrap ( ) ) // Nothing bound on that port
1150- . build ( )
1151- . unwrap ( ) ;
1152- let exporter = build_otlp_metric_exporter ( opts) . unwrap ( ) ;
1153-
1154- let telemopts = TelemetryOptionsBuilder :: default ( )
1155- . metrics ( Arc :: new ( exporter) as Arc < dyn CoreMeter > )
1156- . build ( )
1157- . unwrap ( ) ;
1158-
1159- let rt = CoreRuntime :: new_assume_tokio ( telemopts) . unwrap ( ) ;
1160- let mut starter = CoreWfStarter :: new_with_runtime ( "otel_errors_logged_as_errors" , rt) ;
1161- let _worker = starter. get_worker ( ) . await ;
1162-
1163- // Wait to allow exporter to attempt sending metrics and fail.
1164- // Windows takes a while to fail the network attempt for some reason so 5s.
1165- tokio:: time:: sleep ( Duration :: from_secs ( 5 ) ) . await ;
1166-
1167- let logs = logs. lock ( ) . unwrap ( ) ;
1168- let log_str = String :: from_utf8_lossy ( & logs) ;
1169-
1170- assert ! (
1171- log_str. contains( "ERROR" ) ,
1172- "Expected ERROR log not found in logs: {}" ,
1173- log_str
1174- ) ;
1175- assert ! (
1176- log_str. contains( "Metrics exporter otlp failed with the grpc server returns error" ) ,
1177- "Expected an OTel exporter error message in logs: {}" ,
1178- log_str
1179- ) ;
1180- }
0 commit comments