chore: retry until recovery success

risingwavelabs · Nov 22, 2022 · ae3923e · ae3923e
1 parent 3bc351b
commit ae3923e
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/src/meta/src/barrier/recovery.rs b/src/meta/src/barrier/recovery.rs
@@ -47,8 +47,6 @@ where
 {
     // Retry base interval in milliseconds.
     const RECOVERY_RETRY_BASE_INTERVAL: u64 = 100;
-    // Retry max attempts.
-    const RECOVERY_RETRY_MAX_ATTEMPTS: usize = 10;
     // Retry max interval.
     const RECOVERY_RETRY_MAX_INTERVAL: Duration = Duration::from_secs(10);
 
@@ -57,7 +55,6 @@ where
     fn get_retry_strategy() -> impl Iterator<Item = Duration> {
         ExponentialBackoff::from_millis(Self::RECOVERY_RETRY_BASE_INTERVAL)
             .max_delay(Self::RECOVERY_RETRY_MAX_INTERVAL)
-            .take(Self::RECOVERY_RETRY_MAX_ATTEMPTS)
             .map(jitter)
     }