Increase Wave client max attempts

Signed-off-by: Paolo Di Tommaso <paolo.ditommaso@gmail.com>
nextflow-io · Aug 5, 2023 · fe5dd49 · fe5dd49
1 parent 6d26907
commit fe5dd49
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/plugins/nf-wave/src/main/io/seqera/wave/plugin/config/RetryOpts.groovy b/plugins/nf-wave/src/main/io/seqera/wave/plugin/config/RetryOpts.groovy
@@ -27,9 +27,9 @@ import nextflow.util.Duration
 @ToString(includeNames = true, includePackage = false)
 @CompileStatic
 class RetryOpts {
-    Duration delay = Duration.of('150ms')
+    Duration delay = Duration.of('450ms')
     Duration maxDelay = Duration.of('90s')
-    int maxAttempts = 5
+    int maxAttempts = 10
     double jitter = 0.25
 
     RetryOpts() {

diff --git a/plugins/nf-wave/src/test/io/seqera/wave/plugin/config/RetryOptsTest.groovy b/plugins/nf-wave/src/test/io/seqera/wave/plugin/config/RetryOptsTest.groovy
@@ -29,9 +29,9 @@ class RetryOptsTest extends Specification {
     def 'should create retry config' () {
 
         expect:
-        new RetryOpts().delay == Duration.of('150ms')
+        new RetryOpts().delay == Duration.of('450ms')
         new RetryOpts().maxDelay == Duration.of('90s')
-        new RetryOpts().maxAttempts == 5
+        new RetryOpts().maxAttempts == 10
         new RetryOpts().jitter == 0.25d
 
         and:

diff --git a/plugins/nf-wave/src/test/io/seqera/wave/plugin/config/WaveConfigTest.groovy b/plugins/nf-wave/src/test/io/seqera/wave/plugin/config/WaveConfigTest.groovy
@@ -161,7 +161,8 @@ class WaveConfigTest extends Specification {
         when:
         def opts = new WaveConfig([:])
         then:
-        opts.retryOpts().maxAttempts == 5
+        opts.retryOpts().delay == Duration.of('450ms')
+        opts.retryOpts().maxAttempts == 10
         opts.retryOpts().maxDelay == Duration.of('90s')
 
         when: