Change the scheduled delay config to send all spans before the tests are finished in the 08_opentelemetry exercise

exercises/01_structured_logging/08_opentelemetry/Cargo.toml

@@ -9,7 +9,7 @@ hyper = { workspace = true, features = ["full"] }
 opentelemetry = { workspace = true }
 opentelemetry-otlp = { workspace = true, features = ["tls-roots"] }
 opentelemetry_sdk = { workspace = true, features = ["rt-tokio"] }
-tonic = { workspace = true }
+tonic = { workspace = true, features = ["tls-roots"] }
 tracing = { workspace = true }
 tracing-opentelemetry = { workspace = true }
 tracing-subscriber = { workspace = true, default-features = true, features = ["fmt", "json"] }

exercises/01_structured_logging/08_opentelemetry/src/subscriber.rs

@@ -1,8 +1,9 @@
-use opentelemetry::KeyValue;
 use opentelemetry::trace::TracerProvider;
+use opentelemetry::KeyValue;
 use opentelemetry_otlp::WithExportConfig;
-use opentelemetry_sdk::trace::Tracer;
+use opentelemetry_sdk::trace::{BatchConfigBuilder, Tracer};
 use opentelemetry_sdk::{runtime, Resource};
+use std::time::Duration;
 use tonic::metadata::MetadataMap;
 use tracing_subscriber::layer::SubscriberExt;
 use tracing_subscriber::util::SubscriberInitExt;
@@ -41,10 +42,16 @@ pub fn init_tracer() -> Tracer {
         .with_exporter(
             opentelemetry_otlp::new_exporter()
                 .tonic()
+                .with_tls_config(tonic::transport::ClientTlsConfig::new().with_native_roots())
                 .with_endpoint("https://api.honeycomb.io/api/traces")
                 .with_timeout(std::time::Duration::from_secs(5))
                 .with_metadata(map),
         )
+        .with_batch_config(
+            BatchConfigBuilder::default()
+                .with_scheduled_delay(Duration::from_millis(100))
+                .build(),
+        )
         .install_batch(runtime::Tokio)
         .unwrap()
         .tracer("rust-telemetry-workshop")

exercises/01_structured_logging/08_opentelemetry/tests/failure.rs

@@ -1,5 +1,6 @@
 use opentelemetry::global::shutdown_tracer_provider;
 use opentelemetry_training::init_test_subscriber;
+use std::time::Duration;
 
 #[tokio::test]
 async fn failure() {
@@ -8,6 +9,9 @@ async fn failure() {
 
     opentelemetry_training::get_total(&order_numbers).unwrap_err();
 
+    // Wait for the batch exporter to export all spans before the test is finished
+    tokio::time::sleep(Duration::from_secs(2)).await;
+
     // Ensure all spans are exported
     tokio::task::spawn_blocking(|| shutdown_tracer_provider())
         .await

exercises/01_structured_logging/08_opentelemetry/tests/success.rs

@@ -1,5 +1,6 @@
 use opentelemetry::global::shutdown_tracer_provider;
 use opentelemetry_training::init_test_subscriber;
+use std::time::Duration;
 
 #[tokio::test]
 async fn success() {
@@ -11,6 +12,9 @@ async fn success() {
     // Check that the total is correct.
     assert_eq!(total, 3117);
 
+    // Wait for the batch exporter to export all spans before the test is finished
+    tokio::time::sleep(Duration::from_secs(2)).await;
+
     // Ensure all spans are exported
     tokio::task::spawn_blocking(|| shutdown_tracer_provider())
         .await