treat NoSources as a regular attempt and increment num_attempts

2026-10-26 16:26:14 +00:00 · 2023-06-24 10:29:11 -07:00
parent d8174deb2d
commit 46f83144b8
1 changed files with 1 additions and 1 deletions
@@ -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);
                    }
                };