In WinVector/wrapr: Wrap R Tools for Debugging and Parametric Programming

repos <- c(CRAN="https://cloud.r-project.org")
library("prrd")
orig_dir <- getwd()
# td <- tempdir()
td <- paste0(orig_dir, '/', 'revdep_tests')
package = "wrapr"
packageVersion(package)
date()

parallelCluster <- NULL
ncores <- parallel::detectCores()
#if(ncores > 1) {
#  parallelCluster <- parallel::makeCluster(ncores)
#}


print(orig_dir)
setwd(td)
print(td)

options(repos = repos)
jobsdfe <- enqueueJobs(package=package, directory=td)

print("checking:")
print(jobsdfe)

mk_fn <- function(package, directory, repos) {
  force(package)
  force(directory)
  force(repos)
  function(i) {
    library("prrd")
    options(repos = repos)
    setwd(directory)
    Sys.sleep(1*i)
    dequeueJobs(package=package, directory=directory)
  }
}
f <- mk_fn(package=package, directory=td, repos=repos)

if(!is.null(parallelCluster)) {
  parallel::parLapply(parallelCluster, seq_len(ncores), f)
} else {
  f(0)
}

summariseQueue(package=package, directory=td)

setwd(orig_dir)
if(!is.null(parallelCluster)) {
  parallel::stopCluster(parallelCluster)
}