add errorHandling to job metadata

Author: zfengms

R/doAzureParallel.R

@@ -363,12 +363,23 @@ setHttpTraffic <- function(value = FALSE) {
       metadata <-
         list(enableCloudCombineKeyValuePair, chunkSizeKeyValuePair)
 
+      metadataCount <- 3
       if (!is.null(obj$packages)) {
         packagesKeyValuePair <-
           list(name = "packages",
                value = paste(obj$packages, collapse = ";"))
 
-        metadata[[3]] <-packagesKeyValuePair
+        metadata[[metadataCount]] <-packagesKeyValuePair
+        metadataCount <- metadataCount + 1
+      }
+
+      if (!is.null(obj$errorHandling)) {
+        errorHandlingKeyValuePair <-
+          list(name = "errorHandling",
+               value = as.character(obj$errorHandling))
+
+        metadata[[metadataCount]] <- errorHandlingKeyValuePair
+        metadataCount <- metadataCount + 1
       }
 
       response <- .addJob(

R/utility.R

@@ -149,7 +149,8 @@ getJob <- function(jobId, verbose = TRUE) {
     list(
       chunkSize = 1,
       enableCloudCombine = "TRUE",
-      packages = ""
+      packages = "",
+      errorHandling = "stop"
     )
 
   if (!is.null(job$metadata)) {
@@ -167,6 +168,8 @@ getJob <- function(jobId, verbose = TRUE) {
         fill = TRUE)
     cat(sprintf("\tpackages: %s", metadata$packages),
         fill = TRUE)
+    cat(sprintf("\terrorHandling: %s", metadata$errorHandling),
+        fill = TRUE)
   }
 
   taskCounts <- rAzureBatch::getJobTaskCounts(jobId = jobId)

tests/testthat/test-long-running-job.R

@@ -14,12 +14,14 @@ test_that("Long Running Job Test", {
   cluster <- doAzureParallel::makeCluster(clusterFileName)
   doAzureParallel::registerDoAzureParallel(cluster)
 
-  options <- list(wait = FALSE, job = 'myjob')
+  #options <- list(wait = FALSE, job = 'myjob')
+  options <- list(wait = FALSE)
   '%dopar%' <- foreach::'%dopar%'
   jobId <-
     foreach::foreach(
       i = 1:4,
       .packages = c('httr'),
+      .errorhandling = "stop",
       .options.azure = options
     ) %dopar% {
       mean(1:3)