diff --git a/binaries/coordinator/src/lib.rs b/binaries/coordinator/src/lib.rs index 28644886..c7c303d1 100644 --- a/binaries/coordinator/src/lib.rs +++ b/binaries/coordinator/src/lib.rs @@ -477,6 +477,12 @@ async fn start_inner( let mut disconnected = BTreeSet::new(); for (machine_id, connection) in &mut daemon_connections { if connection.last_heartbeat.elapsed() > Duration::from_secs(15) { + tracing::warn!( + "no heartbeat message from machine `{machine_id}` since {:?}", + connection.last_heartbeat.elapsed() + ) + } + if connection.last_heartbeat.elapsed() > Duration::from_secs(30) { disconnected.insert(machine_id.clone()); continue; }