Now future.tests::check("mirai::daemons(2); plan(future.mirai::mirai_cluster)") works

Author: HenrikBengtsson

NAMESPACE

@@ -32,6 +32,7 @@ importFrom(crayon,silver)
 importFrom(crayon,yellow)
 importFrom(future,availableCores)
 importFrom(future,plan)
+importFrom(future,resetWorkers)
 importFrom(future,sequential)
 importFrom(grDevices,dev.list)
 importFrom(grDevices,dev.off)

NEWS.md

@@ -5,6 +5,9 @@
  * Now `load_tests()` returns a named list, where the names
    corresponds to the test titles.
 
+ * Now `future.tests::check("mirai::daemons(2);
+   plan(future.mirai::mirai_cluster)")` works.
+
 ## Test Updates
 
  * Remove `plan()` test on legacy `constant` backend.

R/check.R

@@ -109,7 +109,9 @@ check <- function(plan = NULL, tags = character(), timeout = NULL, settings = TR
   if (is.character(plan) && length(plan) >= 1L) {
     plan <- unique(plan)
     for (value in plan) {
-      if (!grepl("^plan(.*)$", value)) value <- sprintf("plan(%s)", value)
+      if (!grepl("plan(.*)$", value)) {
+        value <- sprintf("plan(%s)", value)
+      }
       expr <- parse(text = value)
       add_test_plan(expr, substitute = FALSE)
     }

R/run_test.R

@@ -16,6 +16,7 @@
 #'
 #' @return Value of test expression and benchmark information.
 #'
+#' @importFrom future resetWorkers plan
 #' @export
 run_test <- function(test, envir = parent.frame(), local = TRUE, args = list(), defaults = list(), output = "stdout+stderr", timeout = getOption("future.tests.timeout", 30)) {
   stopifnot(inherits(test, "Test"))
@@ -54,7 +55,7 @@ run_test <- function(test, envir = parent.frame(), local = TRUE, args = list(),
   on.exit(pop_state())
 
   if (test$reset_workers) {
-    future::resetWorkers(plan())
+    resetWorkers(plan())
   }
 
   res <- evaluate_expr(test$expr, envir = envir, local = FALSE, output = output, timeout = timeout)

inst/test-db/resolve.R

@@ -4,6 +4,7 @@ make_test(title = "resolve()", args = list(lazy = c(FALSE, TRUE), result = c(FAL
     list(a = 1, b = 42L)
   }, lazy = lazy)
   res <- resolve(f, result = result, recursive = recursive)
+  
   stopifnot(identical(res, f))
 })