Merge pull request #1 from meryacine/unreachable-towers-race-condition

Simplifying the retrier
talaia-labs · Sep 16, 2022 · 12a64d8 · 12a64d8
2 parents 56ec2eb + 9ba6a83
commit 12a64d8
Show file tree

Hide file tree

Showing 3 changed files with 236 additions and 130 deletions.
diff --git a/watchtower-plugin/src/main.rs b/watchtower-plugin/src/main.rs
@@ -615,8 +615,8 @@ async fn main() -> Result<(), Error> {
             60
         };
         tokio::spawn(async move {
-            RetryManager::new(state_clone)
-                .manage_retry(max_elapsed_time, max_interval_time, rx)
+            RetryManager::new(state_clone, rx, max_elapsed_time, max_interval_time)
+                .manage_retry()
                 .await
         });
         plugin.join().await