We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6193331 commit ed0ac2fCopy full SHA for ed0ac2f
1 file changed
crates/kumod/src/queue/config.rs
@@ -156,7 +156,10 @@ impl QueueConfig {
156
}
157
158
pub fn delay_for_attempt(&self, attempt: u16) -> chrono::Duration {
159
- let delay = self.retry_interval.as_secs() * 2u64.saturating_pow(attempt as u32);
+ let delay = self
160
+ .retry_interval
161
+ .as_secs()
162
+ .saturating_mul(2u64.saturating_pow(attempt as u32));
163
164
let delay = match self.max_retry_interval.map(|d| d.as_secs()) {
165
None => delay,
0 commit comments