@@ -192,9 +192,11 @@ fn build_config_and_process(
192
192
#[ cfg( test) ]
193
193
mod tests {
194
194
use crate :: exporter:: config:: build_config_and_process;
195
+ use crate :: new_agent_pipeline;
195
196
use opentelemetry:: sdk:: trace:: Config ;
196
197
use opentelemetry:: sdk:: Resource ;
197
198
use opentelemetry:: KeyValue ;
199
+ use std:: env;
198
200
use std:: sync:: Arc ;
199
201
200
202
#[ test]
@@ -240,14 +242,16 @@ mod tests {
240
242
process. tags[ 0 ] ,
241
243
KeyValue :: new( "service.name" , "override_service" )
242
244
) ;
245
+ }
243
246
244
- // todo: move it to a separate test function
245
- // // OTEL_SERVICE_NAME env var also works
246
- // env::set_var("OTEL_SERVICE_NAME", "test service");
247
- // builder = crate::PipelineBuilder::default();
248
- // let exporter = builder.init_sync_exporter().unwrap();
249
- // assert_eq!(exporter.process.service_name, "test service");
250
- // env::set_var("OTEL_SERVICE_NAME", "")
247
+ #[ test]
248
+ fn test_read_from_env ( ) {
249
+ // OTEL_SERVICE_NAME env var also works
250
+ env:: set_var ( "OTEL_SERVICE_NAME" , "test service" ) ;
251
+ let builder = new_agent_pipeline ( ) ;
252
+ let exporter = builder. build_sync_agent_exporter ( ) . unwrap ( ) ;
253
+ assert_eq ! ( exporter. process. service_name, "test service" ) ;
254
+ env:: set_var ( "OTEL_SERVICE_NAME" , "" )
251
255
}
252
256
}
253
257
0 commit comments