Add DeadlineExceededException to Google Batch retryable exceptions

Signed-off-by: Paolo Di Tommaso <[email protected]>
nextflow-io · Feb 11, 2025 · 944f48f · 944f48f
1 parent 7ad7a23
commit 944f48f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/plugins/nf-google/src/main/nextflow/cloud/google/batch/client/BatchClient.groovy b/plugins/nf-google/src/main/nextflow/cloud/google/batch/client/BatchClient.groovy
@@ -21,6 +21,7 @@ import java.util.concurrent.TimeoutException
 import java.util.function.Predicate
 
 import com.google.api.gax.core.CredentialsProvider
+import com.google.api.gax.rpc.DeadlineExceededException
 import com.google.api.gax.rpc.FixedHeaderProvider
 import com.google.api.gax.rpc.NotFoundException
 import com.google.api.gax.rpc.UnavailableException
@@ -180,6 +181,8 @@ class BatchClient {
             boolean test(Throwable t) {
                 if( t instanceof UnavailableException )
                     return true
+                if( t instanceof DeadlineExceededException )
+                    return true
                 if( t instanceof IOException || t.cause instanceof IOException )
                     return true
                 if( t instanceof TimeoutException || t.cause instanceof TimeoutException )