We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3fa5063 commit 4a65db1Copy full SHA for 4a65db1
1 file changed
aggregation_mode/db/src/orchestrator.rs
@@ -121,7 +121,7 @@ impl DbOrchestrator {
121
Ok(value) => return Ok(value),
122
Err(RetryError::Permanent(err)) => return Err(err),
123
Err(RetryError::Transient(err)) => {
124
- if attempts >= self.retry_config.max_delay_seconds {
+ if attempts >= self.retry_config.max_times {
125
return Err(err);
126
}
127
@@ -164,11 +164,7 @@ impl DbOrchestrator {
164
};
165
166
let scaled = Duration::from_secs_f64(scaled_secs);
167
- if scaled > max {
168
- max
169
- } else {
170
- scaled
171
- }
+ scaled.max(max)
172
173
174
async fn execute_once<T, Q, Fut>(
0 commit comments