diff --git a/ballista/scheduler/src/state/executor_manager.rs b/ballista/scheduler/src/state/executor_manager.rs index 0248a85ef..6779a9426 100644 --- a/ballista/scheduler/src/state/executor_manager.rs +++ b/ballista/scheduler/src/state/executor_manager.rs @@ -326,8 +326,7 @@ impl ExecutorManager { pub(crate) fn is_dead_executor(&self, executor_id: &str) -> bool { self.cluster_state - .get_executor_heartbeat(executor_id) - .map_or(true, |heartbeat| { + .get_executor_heartbeat(executor_id).is_none_or(|heartbeat| { matches!( heartbeat.status, Some(ballista_core::serde::generated::ballista::ExecutorStatus {