diff --git a/crates/kumod/src/queue.rs b/crates/kumod/src/queue.rs index b6da47e4..a3d3b870 100644 --- a/crates/kumod/src/queue.rs +++ b/crates/kumod/src/queue.rs @@ -595,7 +595,7 @@ impl Queue { delivery_protocol: None, }) .await; - return self.force_into_delayed(msg).await; + anyhow::bail!("no non-zero-weighted sources available for {}", self.name); } };