make force_flush() in PushMetricExporter synchronous

opentelemetry-otlp/src/metric.rs

@@ -144,7 +144,7 @@
         self.client.export(metrics).await
     }
 
-    async fn force_flush(&self) -> OTelSdkResult {
+    fn force_flush(&self) -> OTelSdkResult {
         // this component is stateless
         Ok(())
     }

opentelemetry-sdk/CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## vNext
 
+- *Breaking* Make `force_flush()` in `PushMetricExporter` synchronous
+
 ## 0.28.0
 
 Released 2025-Feb-10

opentelemetry-sdk/src/metrics/exporter.rs

@@ -20,7 +20,7 @@ pub trait PushMetricExporter: Send + Sync + 'static {
     ) -> impl std::future::Future<Output = OTelSdkResult> + Send;
 
     /// Flushes any metric data held by an exporter.
-    fn force_flush(&self) -> impl std::future::Future<Output = OTelSdkResult> + Send;
+    fn force_flush(&self) -> OTelSdkResult;
 
     /// Releases any held computational resources.
     ///

opentelemetry-sdk/src/metrics/in_memory_exporter.rs

@@ -272,7 +272,7 @@
             .map_err(|_| OTelSdkError::InternalFailure("Failed to lock metrics".to_string()))
     }
 
-    async fn force_flush(&self) -> OTelSdkResult {
+    fn force_flush(&self) -> OTelSdkResult {
         Ok(()) // In this implementation, flush does nothing
     }
 

opentelemetry-sdk/src/metrics/periodic_reader.rs

@@ -557,7 +557,7 @@
             }
         }
 
-        async fn force_flush(&self) -> OTelSdkResult {
+        fn force_flush(&self) -> OTelSdkResult {
             Ok(())
         }
 
@@ -580,7 +580,7 @@
             Ok(())
         }
 
-        async fn force_flush(&self) -> OTelSdkResult {
+        fn force_flush(&self) -> OTelSdkResult {
             Ok(())
         }
 

opentelemetry-stdout/src/metrics/exporter.rs

@@ -58,7 +58,7 @@
         }
     }
 
-    async fn force_flush(&self) -> OTelSdkResult {
+    fn force_flush(&self) -> OTelSdkResult {
         // exporter holds no state, nothing to flush
         Ok(())
     }