update batch downloads - unstable api gives test routine grief

R/wf_request_batch.R

@@ -3,6 +3,8 @@
 #' to the service. Most ECMWF services are limited to 20 concurrent requests
 #' (default = 2).
 #' @param total_timeout overall timeout limit for all the requests in seconds.
+#' @param retry polling frequency of submitted request for downloading (default =
+#' \code{30} seconds).
 #' @importFrom R6 R6Class
 #'
 #' @rdname wf_request
@@ -13,6 +15,7 @@ wf_request_batch <- function(
     user,
     path = tempdir(),
     time_out = 3600,
+    retry = 5,
     total_timeout = length(request_list)*time_out/workers
 ) {
 
@@ -53,6 +56,7 @@ wf_request_batch <- function(
           queue[[1]],
           user = user[1],
           time_out = time_out[1],
+          retry = retry,
           path = path[1],
           transfer = FALSE
           )

tests/testthat/test_cds.R

@@ -262,7 +262,7 @@ test_that("batch request tests", {
   skip_on_cran()
   skip_if(login_check)
 
-  years <- c(2017,2018)
+  years <- c(2017,2017)
   requests <- lapply(years, function(y) {
     list(
       "dataset_short_name" = "reanalysis-era5-pressure-levels",
@@ -281,6 +281,7 @@ test_that("batch request tests", {
 
   expect_output(wf_request_batch(
     requests,
+    retry = 5,
     user = "2088")
     )