Add retry policy to google batch describe task (#5356)

Signed-off-by: Ben Sherman <bentshermann@gmail.com>
nextflow-io · Oct 3, 2024 · 64bb5a9 · 64bb5a9
1 parent 324de3d
commit 64bb5a9
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -110,7 +110,7 @@ class BatchClient {
 
     Task describeTask(String jobId, String taskId) {
         final name = TaskName.of(projectId, location, jobId, 'group0', taskId)
-        return batchServiceClient.getTask(name)
+        return apply(()-> batchServiceClient.getTask(name))
     }
 
     void deleteJob(String jobId) {