Skip to content

Commit ed8713c

Browse files
committed
fix(telemetry): update BatchLogProcessor to be async
Signed-off-by: Andrew Steurer <[email protected]>
1 parent ef3f425 commit ed8713c

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ lazy_static = "1.5"
148148
opentelemetry = "0.28"
149149
# The default `reqwest-blocking-client` causes a runtime panic
150150
opentelemetry-otlp = { version = "0.28", default-features = false, features = ["http-proto", "reqwest-client", "logs"]}
151-
opentelemetry_sdk = {version = "0.28", features = ["experimental_metrics_periodicreader_with_async_runtime", "experimental_trace_batch_span_processor_with_async_runtime"]}
151+
opentelemetry_sdk = {version = "0.28", features = ["experimental_metrics_periodicreader_with_async_runtime", "experimental_trace_batch_span_processor_with_async_runtime", "experimental_logs_batch_log_processor_with_async_runtime"]}
152152
path-absolutize = "3"
153153
pin-project-lite = "0.2.16"
154154
quote = "1"

crates/telemetry/src/logs.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,9 @@ use std::{ascii::escape_default, sync::OnceLock};
33
use anyhow::bail;
44
use opentelemetry::logs::{LogRecord, Logger, LoggerProvider};
55
use opentelemetry_sdk::{
6-
logs::{BatchConfigBuilder, BatchLogProcessor, SdkLogger},
6+
logs::{log_processor_with_async_runtime::BatchLogProcessor, BatchConfigBuilder, SdkLogger},
77
resource::{EnvResourceDetector, ResourceDetector, TelemetryResourceDetector},
8+
runtime::Tokio,
89
Resource,
910
};
1011

@@ -97,7 +98,7 @@ pub(crate) fn init_otel_logging_backend(spin_version: String) -> anyhow::Result<
9798
let provider = opentelemetry_sdk::logs::SdkLoggerProvider::builder()
9899
.with_resource(resource)
99100
.with_log_processor(
100-
BatchLogProcessor::builder(exporter)
101+
BatchLogProcessor::builder(exporter, Tokio)
101102
.with_batch_config(BatchConfigBuilder::default().build())
102103
.build(),
103104
)

0 commit comments

Comments
 (0)