ROBUSTNESS: Test MPI clusters when NOT_CRAN=true [#805]

Author: HenrikBengtsson

DESCRIPTION

@@ -1,5 +1,5 @@
 Package: future
-Version: 1.67.0-9003
+Version: 1.67.0-9004
 Title: Unified Parallel and Distributed Processing in R for Everyone
 Depends:
     R (>= 3.2.0)
@@ -13,6 +13,7 @@ Imports:
 Suggests:
     methods,
     RhpcBLASctl,
+    Rmpi,
     R.rsp,
     markdown
 VignetteBuilder: R.rsp

inst/testme/_prologue/090.context.R

@@ -1,5 +1,3 @@
-fullTest <- (Sys.getenv("_R_CHECK_FULL_") != "")
-
 covr_testing <- ("covr" %in% loadedNamespaces())
 on_macos <- grepl("^darwin", R.version$os)
 on_githubactions <- as.logical(Sys.getenv("GITHUB_ACTIONS", "FALSE"))

inst/testme/test-mpi.R

@@ -9,22 +9,23 @@ makeClusterMPI <- parallelly::makeClusterMPI
 message("*** MPI ...")
 
 pkg <- "Rmpi"
-if (fullTest && requireNamespace(pkg, quietly = TRUE)) {
+if (requireNamespace(pkg, quietly = TRUE)) {
   cl <- makeClusterMPI(availableCores())
   str(cl)
 
   plan(cluster, workers = cl)
 
-  fs <- lapply(1:2, FUN = function(x) future({
+  xs <- seq_len(nbrOfWorkers() + 1)
+  fs <- lapply(xs, FUN = function(x) future({
     printf("Hostname: %s\n", Sys.info()[["nodename"]])
     printf("PID: %d\n", Sys.getpid())
     Sys.sleep(0.5)
-    x^2
+    -x
   }))
   print(fs)
   vs <- value(fs)
   print(vs)
-  stopifnot(all(unlist(vs) == c(1, 4)))
+  stopifnot(all(unlist(vs) == -xs))
 
   stopCluster(cl)
   str(cl)