ignore chunks.as.arrayjobs if not supported

R/submitJobs.R

@@ -123,8 +123,13 @@ submitJobs = function(ids = NULL, resources = list(), reg = getDefaultRegistry()
     assertCount(resources$ncpus, positive = TRUE)
   if (hasName(resources, "measure.memory"))
     assertFlag(resources$measure.memory)
-  if (hasName(resources, "chunks.as.arrayjobs"))
+  if (hasName(resources, "chunks.as.arrayjobs")) {
     assertFlag(resources$chunks.as.arrayjobs)
+    if (resources$chunks.as.arrayjobs && is.na(reg$cluster.functions$array.var)) {
+      info("Ignoring resource 'chunks.as.arrayjobs', not supported by cluster functions '%s'", reg$cluster.functions$name)
+      resources$chunks.as.arrayjobs = NULL
+    }
+  }
 
   ids = convertIds(reg, ids, default = .findNotSubmitted(reg = reg), keep.extra = "chunk")
   if (nrow(ids) == 0L)

R/waitForJobs.R

@@ -21,7 +21,6 @@
 #'   one job terminated with an exception.
 #' @export
 waitForJobs = function(ids = NULL, sleep = 10, timeout = 604800, stop.on.error = FALSE, reg = getDefaultRegistry()) {
-  "!DEBUG Starting waitForJobs"
   assertRegistry(reg, writeable = FALSE, sync = TRUE)
   assertNumeric(sleep, len = 1L, lower = 0, finite = TRUE)
   assertNumeric(timeout, len = 1L, lower = sleep)
@@ -43,7 +42,7 @@ waitForJobs = function(ids = NULL, sleep = 10, timeout = 604800, stop.on.error =
     return(TRUE)
 
   batch.ids = getBatchIds(reg)
-  "!DEBUG Using `nrow(ids)` ids and `nrow(batch.ids)` batch ids"
+  "!DEBUG `match.call()[1]`: Using `nrow(ids)` ids and `nrow(batch.ids)` batch ids"
   if (nrow(batch.ids) == 0L)
     return(nrow(.findErrors(reg, ids)) == 0L)