make the span exporter flush result after export

open-telemetry · Dec 12, 2024 · f210998 · f210998
1 parent a0261fa
commit f210998
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/Sources/OpenTelemetrySdk/Trace/SpanProcessors/BatchSpanProcessor.swift b/Sources/OpenTelemetrySdk/Trace/SpanProcessors/BatchSpanProcessor.swift
@@ -222,7 +222,12 @@ private class BatchWorker: Thread {
     stride(from: 0, to: spanList.endIndex, by: maxExportBatchSize).forEach {
       var spansToExport = spanList[$0 ..< min($0 + maxExportBatchSize, spanList.count)].map { $0.toSpanData() }
       willExportCallback?(&spansToExport)
-      let result = spanExporter.export(spans: spansToExport, explicitTimeout: explicitTimeout)
+      var result = spanExporter.export(spans: spansToExport, explicitTimeout: explicitTimeout)
+
+      if result == .success {
+        result = spanExporter.flush(explicitTimeout: explicitTimeout)
+      }
+
       if result == .success {
         cond.lock()
         processedSpansCounter?.add(value: spanList.count, attribute:  [