diff --git a/hive-c0re/src/broker.rs b/hive-c0re/src/broker.rs
index 5a701ce8..e28a698e 100644
--- a/hive-c0re/src/broker.rs
+++ b/hive-c0re/src/broker.rs
@@ -263,21 +263,6 @@ impl Broker {
         Ok(u64::try_from(n.max(0)).unwrap_or(0))
     }
 
-    /// Returns true when the recipient already has at least one
-    /// undelivered message from `sender` in the broker. Used by the
-    /// scheduler to avoid piling up repeated prompts when an agent is
-    /// slow or was briefly offline.
-    pub fn has_pending_from(&self, recipient: &str, sender: &str) -> Result<bool> {
-        let conn = self.conn.lock().unwrap();
-        let n: i64 = conn.query_row(
-            "SELECT COUNT(*) FROM messages
-              WHERE recipient = ?1 AND sender = ?2 AND delivered_at IS NULL",
-            params![recipient, sender],
-            |row| row.get(0),
-        )?;
-        Ok(n > 0)
-    }
-
     /// Returns true when the recipient already has at least one
     /// undelivered message from `sender` with exactly `body` in the
     /// broker. Used by the scheduler to skip re-delivery of the same