From 944f48f9b52d47032bf57e16cfe11fe9410972b2 Mon Sep 17 00:00:00 2001 From: Paolo Di Tommaso Date: Tue, 11 Feb 2025 23:47:02 +0100 Subject: [PATCH] Add DeadlineExceededException to Google Batch retryable exceptions Signed-off-by: Paolo Di Tommaso --- .../main/nextflow/cloud/google/batch/client/BatchClient.groovy | 3 +++ 1 file changed, 3 insertions(+) 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 index d85d42b581..e1e1e0c437 100644 --- 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 )