We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
BatchSpanProcessor
1 parent aa0d81b commit ce34c37Copy full SHA for ce34c37
opentelemetry-sdk/src/trace/span_processor_with_async_runtime.rs
@@ -250,6 +250,8 @@ where
250
if !self.export_tasks.is_empty()
251
&& self.export_tasks.len() == self.config.max_concurrent_exports
252
{
253
+ // TODO: Refactor to avoid stopping message processing to not delay
254
+ // shutdown/resource set because of export saturation.
255
self.export_tasks.next().await;
256
}
257
@@ -307,7 +309,7 @@ where
307
309
true
308
310
311
- fn export(&mut self) -> impl Future<Output = OTelSdkResult> + use<E, R> {
312
+ fn export(&mut self) -> impl Future<Output = OTelSdkResult> {
313
let spans = self.spans.drain(..).collect::<Vec<_>>();
314
let exporter = self.exporter.clone();
315
let runtime = self.runtime.clone();
0 commit comments