diff --git a/safekeeper/src/timeline_manager.rs b/safekeeper/src/timeline_manager.rs index 8077d1d30c..b1d1c3be91 100644 --- a/safekeeper/src/timeline_manager.rs +++ b/safekeeper/src/timeline_manager.rs @@ -120,7 +120,8 @@ pub async fn main_task( tli.broker_active .store(is_active, std::sync::atomic::Ordering::SeqCst); - // wait until something changes + // wait until something changes. tx channels are stored under Arc, so they will not be + // dropped until the manager task is finished. tokio::select! { _ = cancellation_rx.changed() => { // timeline was deleted