Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 4 additions & 1 deletion src/sources/opentelemetry/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -257,7 +257,10 @@ impl SourceConfig for OpentelemetryConfig {
filters,
cx.shutdown,
self.http.keepalive.clone(),
);
)
.map_err(|error| {
error!(message = "Source future failed.", %error);
Comment thread
pront marked this conversation as resolved.
Outdated
});

Ok(join(grpc_source, http_source).map(|_| Ok(())).boxed())
}
Expand Down
Loading