diff --git a/crates/openfang-kernel/src/heartbeat.rs b/crates/openfang-kernel/src/heartbeat.rs index f682157f9..d4b693b25 100644 --- a/crates/openfang-kernel/src/heartbeat.rs +++ b/crates/openfang-kernel/src/heartbeat.rs @@ -130,7 +130,7 @@ impl Default for RecoveryTracker { /// /// This is a pure function — it doesn't start a background task. /// The caller (kernel) can run this periodically or in a background task. -pub fn check_agents(registry: &AgentRegistry, config: &HeartbeatConfig) -> Vec { +pub fn check_agents(registry: &AgentRegistry, _config: &HeartbeatConfig) -> Vec { let now = Utc::now(); let mut statuses = Vec::new(); @@ -143,16 +143,19 @@ pub fn check_agents(registry: &AgentRegistry, config: &HeartbeatConfig) -> Vec = entry_ref .manifest .autonomous .as_ref() - .map(|a| a.heartbeat_interval_secs * UNRESPONSIVE_MULTIPLIER) - .unwrap_or(config.default_timeout_secs) as i64; + .map(|a| (a.heartbeat_interval_secs * UNRESPONSIVE_MULTIPLIER) as i64); - // Crashed agents are always considered unresponsive - let unresponsive = entry_ref.state == AgentState::Crashed || inactive_secs > timeout_secs; + let unresponsive = match timeout_secs { + Some(t) => entry_ref.state == AgentState::Crashed || inactive_secs > t, + None => entry_ref.state == AgentState::Crashed, + }; if unresponsive && entry_ref.state == AgentState::Running { warn!(