rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-05-28 02:20:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix span for WAL removal task (#7930)

Browse Source 
During refactoring in https://github.com/neondatabase/neon/pull/7887 I
forgot to add "WAL removal" span with ttid. This commit fixes it.
This commit is contained in:
Arthur Petukhovsky
2024-06-01 12:23:59 +01:00
committed by GitHub
parent e98bc4fd2b
commit a345cf3fc6
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
safekeeper/src/timeline_manager.rs
View File

@@ -10,7 +10,7 @@ use std::{
use postgres_ffi::XLogSegNo;
use tokio::task::{JoinError, JoinHandle};
use tracing::{info, instrument, warn};
use tracing::{info, info_span, instrument, warn, Instrument};
use utils::lsn::Lsn;
use crate::{
@@ -346,10 +346,13 @@ async fn update_wal_removal(
&tli.read_shared_state().await.sk.wal_store,
removal_horizon_segno,
);
*wal_removal_task = Some(tokio::spawn(async move {
remover.await?;
Ok(removal_horizon_segno)
}));
*wal_removal_task = Some(tokio::spawn(
async move {
remover.await?;
Ok(removal_horizon_segno)
}
.instrument(info_span!("WAL removal", ttid=%tli.ttid)),
));
}
}