Skip to content

Commit

Permalink
merge: #3282
Browse files Browse the repository at this point in the history
3282: chore(telemetry): add a span around tracing level change events r=fnichol a=fnichol

This change will ensure that anytime we change the telemetry tracing log levels, we get an `INFO` level span transmitted to the OpenTelemetry endpoint with its associated events.

<img src="https://media4.giphy.com/media/pHWFj7mt7qyBs2XYC6/giphy.gif"/>

Co-authored-by: Fletcher Nichol <[email protected]>
  • Loading branch information
si-bors-ng[bot] and fnichol authored Feb 7, 2024
2 parents 170af4a + 5db972e commit b3a02d0
Showing 1 changed file with 21 additions and 11 deletions.
32 changes: 21 additions & 11 deletions lib/telemetry-application-rs/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -580,21 +580,31 @@ impl TelemetryUpdateTask {
while let Some(command) = self.update_command_rx.recv().await {
match command {
TelemetryCommand::TracingLevel { level, wait } => {
if let Err(err) = self.update_tracing_level(level) {
warn!(
task = Self::NAME,
error = ?err,
"failed to update tracing level, using prior value",
);
}
if let Some(tx) = wait {
if let Err(err) = tx.send(()) {
// We want a span around the update logging so this is transmitted to our
// OpenTelemetry endpoint. We may use this span (and associated events) as a
// deployment mutation event, for example adding a mark in Honeycomb.
//
// Also note that we're using the `in_scope` method as none of the containing
// code is asynchronous--if there were async code then we'd use the
// `.instrument()` combinator on the future.
let span = info_span!("telemetry_update_task.update_tracing_level");
span.in_scope(|| {
if let Err(err) = self.update_tracing_level(level) {
warn!(
task = Self::NAME,
error = ?err,
"receiver already closed when waiting on changing tracing level",
"failed to update tracing level, using prior value",
);
}
}
if let Some(tx) = wait {
if let Err(err) = tx.send(()) {
warn!(
error = ?err,
"receiver already closed when waiting on changing tracing level",
);
}
}
})
}
TelemetryCommand::Shutdown(token) => {
if !self.is_shutdown {
Expand Down

0 comments on commit b3a02d0

Please sign in to comment.