Add force_flush exporter call to SimpleLogProcessor

open-telemetry · Nov 18, 2024 · 9290828 · 9290828
1 parent 6974ced
commit 9290828
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/opentelemetry-sdk/src/logs/log_processor.rs b/opentelemetry-sdk/src/logs/log_processor.rs
@@ -129,7 +129,11 @@ impl LogProcessor for SimpleLogProcessor {
     }
 
     fn force_flush(&self) -> LogResult<()> {
-        Ok(())
+        if let Ok(mut exporter) = self.exporter.lock() {
+            exporter.force_flush()
+        } else {
+            Err(LogError::MutexPoisoned("SimpleLogProcessor".into()))
+        }
     }
 
     fn shutdown(&self) -> LogResult<()> {