Last updated on 2024-05-15 01:49:27 CEST.
| Package | ERROR | NOTE | OK |
|---|---|---|---|
| ACNE | 13 | ||
| aroma.affymetrix | 9 | 4 | |
| aroma.apd | 2 | 10 | |
| aroma.cn | 2 | 11 | |
| aroma.core | 13 | ||
| calmate | 1 | 12 | |
| dChipIO | 12 | ||
| doFuture | 12 | ||
| future | 13 | ||
| future.apply | 13 | ||
| future.batchtools | 12 | ||
| future.callr | 12 | ||
| future.mirai | 1 | 12 | |
| future.tests | 12 | ||
| globals | 13 | ||
| listenv | 13 | ||
| matrixStats | 13 | ||
| parallelly | 13 | ||
| port4me | 13 | ||
| profmem | 1 | 11 | |
| progressr | 12 | ||
| PSCBS | 13 | ||
| R.cache | 9 | 3 | |
| R.devices | 13 | ||
| R.filesets | 13 | ||
| R.huge | 13 | ||
| R.matlab | 9 | 3 | |
| R.methodsS3 | 12 | ||
| R.oo | 13 | ||
| R.rsp | 13 | ||
| R.utils | 12 | ||
| seguid | 13 | ||
| startup | 12 | ||
| TopDom | 9 | 3 |
Current CRAN status: OK: 13
Current CRAN status: NOTE: 9, OK: 4
Version: 3.2.2
Check: installed package size
Result: NOTE
installed size is 5.9Mb
sub-directories of 1Mb or more:
R 2.3Mb
help 1.2Mb
testScripts 1.3Mb
Flavors: r-devel-linux-x86_64-fedora-clang, r-devel-windows-x86_64, r-release-macos-arm64, r-release-macos-x86_64, r-release-windows-x86_64, r-oldrel-macos-arm64, r-oldrel-macos-x86_64, r-oldrel-windows-x86_64
Version: 3.2.2
Check: package dependencies
Result: NOTE
Packages suggested but not available for checking: 'oligo', 'pdInfoBuilder'
Flavor: r-devel-linux-x86_64-fedora-gcc
Version: 3.2.2
Check: Rd cross-references
Result: NOTE
Package unavailable to check Rd xrefs: ‘oligo’
Flavor: r-devel-linux-x86_64-fedora-gcc
Version: 3.2.2
Check: package dependencies
Result: NOTE
Package suggested but not available for checking: ‘AffymetrixDataTestFiles’
Flavors: r-release-macos-arm64, r-release-macos-x86_64
Version: 3.2.2
Check: package dependencies
Result: NOTE
Packages suggested but not available for checking:
'affxparser', 'oligo', 'oligoClasses', 'pdInfoBuilder',
'AffymetrixDataTestFiles'
Flavors: r-oldrel-macos-arm64, r-oldrel-macos-x86_64
Version: 3.2.2
Check: Rd cross-references
Result: NOTE
Packages unavailable to check Rd xrefs: ‘affxparser’, ‘oligo’, ‘oligoClasses’
Flavors: r-oldrel-macos-arm64, r-oldrel-macos-x86_64
Current CRAN status: NOTE: 2, OK: 10
Version: 0.7.0
Check: package dependencies
Result: NOTE
Package suggested but not available for checking: ‘affxparser’
Flavors: r-oldrel-macos-arm64, r-oldrel-macos-x86_64
Version: 0.7.0
Check: Rd cross-references
Result: NOTE
Package unavailable to check Rd xrefs: ‘affxparser’
Flavors: r-oldrel-macos-arm64, r-oldrel-macos-x86_64
Current CRAN status: NOTE: 2, OK: 11
Version: 1.7.1
Check: package dependencies
Result: NOTE
Package suggested but not available for checking: ‘GLAD’
Flavors: r-oldrel-macos-arm64, r-oldrel-macos-x86_64
Current CRAN status: NOTE: 13
Version: 3.3.1
Check: package dependencies
Result: NOTE
Packages suggested but not available for checking:
'sfit', 'expectile', 'HaarSeg', 'mpcbs'
Flavors: r-devel-linux-x86_64-debian-clang, r-devel-linux-x86_64-debian-gcc, r-devel-linux-x86_64-fedora-clang, r-devel-linux-x86_64-fedora-gcc, r-devel-windows-x86_64, r-patched-linux-x86_64, r-release-linux-x86_64, r-release-macos-arm64, r-release-macos-x86_64, r-release-windows-x86_64, r-oldrel-windows-x86_64
Version: 3.3.1
Check: package dependencies
Result: NOTE
Packages suggested but not available for checking:
'GLAD', 'sfit', 'expectile', 'HaarSeg', 'mpcbs'
Flavors: r-oldrel-macos-arm64, r-oldrel-macos-x86_64
Version: 3.3.1
Check: Rd cross-references
Result: NOTE
Package unavailable to check Rd xrefs: ‘GLAD’
Flavors: r-oldrel-macos-arm64, r-oldrel-macos-x86_64
Current CRAN status: ERROR: 1, OK: 12
Version: 0.13.0
Check: package dependencies
Result: ERROR
Package required but not available: ‘aroma.core’
See section ‘The DESCRIPTION file’ in the ‘Writing R Extensions’
manual.
Flavor: r-oldrel-macos-arm64
Current CRAN status: OK: 12
Current CRAN status: OK: 12
Current CRAN status: OK: 13
Current CRAN status: OK: 13
Current CRAN status: OK: 12
Current CRAN status: OK: 12
Current CRAN status: ERROR: 1, OK: 12
Version: 0.2.0
Check: tests
Result: ERROR
Running 'demo.R' [2s]
Running 'dotdotdot.R' [2s]
Running 'future,labels.R' [2s]
Running 'future,lazy.R' [2s]
Running 'future.tests,mirai_cluster.R' [16s]
Running 'future.tests-mirai_multisession.R' [19s]
Running 'globals,formulas.R' [2s]
Running 'globals,manual.R' [2s]
Running 'globals,nested.R' [1s]
Running 'globals,subassignment.R' [2s]
Running 'globals,tricky.R' [2s]
Running 'mirai_cluster,worker-termination.R' [1s]
Running 'mirai_cluster.R' [2s]
Running 'nbrOfWorkers.R' [1s]
Running 'plan.R' [1s]
Running 'rng.R' [1s]
Running 'stdout.R' [2s]
Running 'zzz,future_lapply.R' [13s]
Running the tests in 'tests/plan.R' failed.
Complete output:
> source("incl/start,load-only.R")
[16:25:19.244] Detected 'R CMD check':
- adjusting defaults to be a good citizen
[16:25:19.246] Set package option 'parallelly.availableCores.methods'
[16:25:19.247] Environment variable 'R_PARALLELLY_AVAILABLECORES_METHODS' not set
[16:25:19.247] Set package option 'parallelly.availableCores.fallback'
[16:25:19.248] Environment variable 'R_PARALLELLY_AVAILABLECORES_FALLBACK' not set
[16:25:19.248] Set package option 'parallelly.availableCores.min'
[16:25:19.248] Environment variable 'R_PARALLELLY_AVAILABLECORES_MIN' not set
[16:25:19.249] Set package option 'parallelly.availableCores.system'
[16:25:19.249] Environment variable 'R_PARALLELLY_AVAILABLECORES_SYSTEM' not set
[16:25:19.249] Set package option 'parallelly.availableCores.logical'
[16:25:19.250] Environment variable 'R_PARALLELLY_AVAILABLECORES_LOGICAL' not set
[16:25:19.250] Set package option 'parallelly.availableCores.omit'
[16:25:19.250] Environment variable 'R_PARALLELLY_AVAILABLECORES_OMIT' not set
[16:25:19.250] Set package option 'parallelly.availableWorkers.methods'
[16:25:19.251] Environment variable 'R_PARALLELLY_AVAILABLEWORKERS_METHODS' not set
[16:25:19.251] Set package option 'parallelly.maxWorkers.localhost'
[16:25:19.251] Environment variable 'R_PARALLELLY_MAXWORKERS_LOCALHOST' not set
[16:25:19.252] Set package option 'parallelly.maxWorkers.localhost.ignore'
[16:25:19.252] Environment variable 'R_PARALLELLY_MAXWORKERS_LOCALHOST_IGNORE' not set
[16:25:19.252] Set package option 'parallelly.fork.enable'
[16:25:19.253] Environment variable 'R_PARALLELLY_FORK_ENABLE' not set
[16:25:19.253] Set package option 'parallelly.supportsMulticore.disableOn'
[16:25:19.253] Environment variable 'R_PARALLELLY_SUPPORTSMULTICORE_DISABLEON' not set
[16:25:19.254] Set package option 'parallelly.supportsMulticore.unstable'
[16:25:19.254] Environment variable 'R_PARALLELLY_SUPPORTSMULTICORE_UNSTABLE' not set
[16:25:19.254] Set package option 'parallelly.makeNodePSOCK.setup_strategy'
[16:25:19.255] Environment variable 'R_PARALLELLY_MAKENODEPSOCK_SETUP_STRATEGY' not set
[16:25:19.255] Set package option 'parallelly.makeNodePSOCK.validate'
[16:25:19.256] Environment variable 'R_PARALLELLY_MAKENODEPSOCK_VALIDATE' not set
[16:25:19.256] Set package option 'parallelly.makeNodePSOCK.connectTimeout'
[16:25:19.256] R_PARALLELLY_MAKENODEPSOCK_CONNECTTIMEOUT='120'
[16:25:19.256] Coercing from character to numeric: '120'
[16:25:19.257] => options("parallelly.makeNodePSOCK.connectTimeout" = '120') [n=1, mode=double]
[16:25:19.257] Set package option 'parallelly.makeNodePSOCK.timeout'
[16:25:19.258] R_PARALLELLY_MAKENODEPSOCK_TIMEOUT='120'
[16:25:19.258] Coercing from character to numeric: '120'
[16:25:19.258] => options("parallelly.makeNodePSOCK.timeout" = '120') [n=1, mode=double]
[16:25:19.259] Set package option 'parallelly.makeNodePSOCK.useXDR'
[16:25:19.259] Environment variable 'R_PARALLELLY_MAKENODEPSOCK_USEXDR' not set
[16:25:19.259] Set package option 'parallelly.makeNodePSOCK.socketOptions'
[16:25:19.260] Environment variable 'R_PARALLELLY_MAKENODEPSOCK_SOCKETOPTIONS' not set
[16:25:19.260] Set package option 'parallelly.makeNodePSOCK.rshcmd'
[16:25:19.261] Environment variable 'R_PARALLELLY_MAKENODEPSOCK_RSHCMD' not set
[16:25:19.261] Set package option 'parallelly.makeNodePSOCK.rshopts'
[16:25:19.261] Environment variable 'R_PARALLELLY_MAKENODEPSOCK_RSHOPTS' not set
[16:25:19.262] Set package option 'parallelly.makeNodePSOCK.tries'
[16:25:19.262] Environment variable 'R_PARALLELLY_MAKENODEPSOCK_TRIES' not set
[16:25:19.263] Set package option 'parallelly.makeNodePSOCK.tries.delay'
[16:25:19.263] Environment variable 'R_PARALLELLY_MAKENODEPSOCK_TRIES_DELAY' not set
[16:25:19.263] Set package option 'parallelly.makeNodePSOCK.rscript_label'
[16:25:19.264] R_PARALLELLY_MAKENODEPSOCK_RSCRIPT_LABEL='TRUE'
[16:25:19.264] => options("parallelly.makeNodePSOCK.rscript_label" = 'TRUE') [n=1, mode=character]
[16:25:19.264] Set package option 'parallelly.makeNodePSOCK.sessionInfo.pkgs'
[16:25:19.265] R_PARALLELLY_MAKENODEPSOCK_SESSIONINFO_PKGS='TRUE'
[16:25:19.265] => options("parallelly.makeNodePSOCK.sessionInfo.pkgs" = 'TRUE') [n=1, mode=character]
[16:25:19.265] Set package option 'parallelly.makeNodePSOCK.autoKill'
[16:25:19.265] R_PARALLELLY_MAKENODEPSOCK_AUTOKILL='TRUE'
[16:25:19.265] Coercing from character to logical: 'TRUE'
[16:25:19.266] => options("parallelly.makeNodePSOCK.autoKill" = 'TRUE') [n=1, mode=logical]
[16:25:19.266] Set package option 'parallelly.makeNodePSOCK.master.localhost.hostname'
[16:25:19.266] Environment variable 'R_PARALLELLY_MAKENODEPSOCK_MASTER_LOCALHOST_HOSTNAME' not set
[16:25:19.266] Set package option 'parallelly.makeNodePSOCK.port.increment'
[16:25:19.267] Environment variable 'R_PARALLELLY_MAKENODEPSOCK_PORT_INCREMENT' not set
[16:25:19.268] parallelly-specific environment variables:
- R_PARALLELLY_MAKENODEPSOCK_AUTOKILL='TRUE'
- R_PARALLELLY_MAKENODEPSOCK_CONNECTTIMEOUT='120'
- R_PARALLELLY_MAKENODEPSOCK_RSCRIPT_LABEL='TRUE'
- R_PARALLELLY_MAKENODEPSOCK_SESSIONINFO_PKGS='TRUE'
- R_PARALLELLY_MAKENODEPSOCK_TIMEOUT='120'
- R_PARALLELLY_RANDOM_PORTS='20000:39999'
[16:25:19.279] Future-specific environment variables:
[16:25:19.280] Environment variable 'R_FUTURE_DEMO_MANDELBROT_REGION' not set
[16:25:19.280] Environment variable 'R_FUTURE_DEMO_MANDELBROT_NROW' not set
[16:25:19.280] Environment variable 'R_FUTURE_DEPRECATED_IGNORE' not set
[16:25:19.280] Environment variable 'R_FUTURE_DEPRECATED_DEFUNCT' not set
[16:25:19.280] Environment variable 'R_FUTURE_FORK_MULTITHREADING_ENABLE' not set
[16:25:19.280] Environment variable 'R_FUTURE_GLOBALS_MAXSIZE' not set
[16:25:19.281] Environment variable 'R_FUTURE_GLOBALS_ONMISSING' not set
[16:25:19.281] Environment variable 'R_FUTURE_GLOBALS_ONREFERENCE' not set
[16:25:19.281] Environment variable 'R_FUTURE_GLOBALS_METHOD' not set
[16:25:19.281] Environment variable 'R_FUTURE_GLOBALS_RESOLVE' not set
[16:25:19.281] Environment variable 'R_FUTURE_LAZY_ASSERTOWNER' not set
[16:25:19.281] Environment variable 'R_FUTURE_PLAN' not set
[16:25:19.281] Environment variable 'R_FUTURE_PLAN_DISALLOW' not set
[16:25:19.282] Environment variable 'R_FUTURE_PSOCK_RELAY_IMMEDIATE' not set
[16:25:19.282] Environment variable 'R_FUTURE_RELAY_IMMEDIATE' not set
[16:25:19.282] Environment variable 'R_FUTURE_RESOLVE_RECURSIVE' not set
[16:25:19.282] Environment variable 'R_FUTURE_ALIVE_TIMEOUT' not set
[16:25:19.282] Environment variable 'R_FUTURE_RESOLVED_TIMEOUT' not set
[16:25:19.282] Environment variable 'R_FUTURE_CLUSTER_RESOLVED_TIMEOUT' not set
[16:25:19.283] Environment variable 'R_FUTURE_MULTICORE_RESOLVED_TIMEOUT' not set
[16:25:19.283] Environment variable 'R_FUTURE_ONFUTURECONDITION_KEEPFUTURE' not set
[16:25:19.283] Environment variable 'R_FUTURE_RNG_ONMISUSE' not set
[16:25:19.283] Environment variable 'R_FUTURE_GLOBALENV_ONMISUSE' not set
[16:25:19.283] Environment variable 'R_FUTURE_WAIT_TIMEOUT' not set
[16:25:19.283] Environment variable 'R_FUTURE_WAIT_INTERVAL' not set
[16:25:19.284] Environment variable 'R_FUTURE_WAIT_ALPHA' not set
[16:25:19.284] Environment variable 'R_FUTURE_ASSIGN_GLOBALS_EXCLUDE' not set
[16:25:19.284] Environment variable 'R_FUTURE_OUTPUT_WINDOWS_REENCODE' not set
[16:25:19.284] Environment variable 'R_FUTURE_GLOBALS_GLOBALSOF_LOCALS' not set
[16:25:19.284] Environment variable 'R_FUTURE_STATE_ONINVALID' not set
[16:25:19.285] Environment variable 'R_FUTURE_JOURNAL' not set
[16:25:19.285] Environment variable 'R_FUTURE_GLOBALS_KEEPWHERE' not set
[16:25:19.286] R process uuid: 919e64ae-fff7-19de-3b00-706fbddf0aa7
[16:25:19.286] Setting plan('default')
[16:25:19.287] plan(): Setting new future strategy stack:
[16:25:19.288] List of future strategies:
[16:25:19.288] 1. sequential:
[16:25:19.288] - args: function (..., envir = parent.frame(), workers = "<NULL>")
[16:25:19.288] - tweaked: FALSE
[16:25:19.288] - call: NULL
[16:25:19.289] plan(): nbrOfWorkers() = 1
[16:25:19.363] plan(): Setting new future strategy stack:
[16:25:19.363] List of future strategies:
[16:25:19.363] 1. mirai_multisession:
[16:25:19.363] - args: function (expr, substitute = TRUE, envir = parent.frame(), ..., workers = availableCores())
[16:25:19.363] - tweaked: FALSE
[16:25:19.363] - call: future::plan(future.mirai::mirai_multisession)
[16:25:19.383] plan(): plan_init() of 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function' ...
[16:25:19.383] < mirai | $data >
[16:25:19.389] getGlobalsAndPackages() ...
[16:25:19.389] Not searching for globals
[16:25:19.389] - globals: [0] <none>
[16:25:19.390] getGlobalsAndPackages() ... DONE
[16:25:19.390] getGlobalsAndPackages() ...
[16:25:19.390]
[16:25:19.391] - globals: [0] <none>
[16:25:19.391] getGlobalsAndPackages() ... DONE
[16:25:19.787] Packages needed by the future expression (n = 0): <none>
[16:25:19.787] Packages needed by future strategies (n = 0): <none>
[16:25:19.788] {
[16:25:19.788] {
[16:25:19.788] {
[16:25:19.788] ...future.startTime <- base::Sys.time()
[16:25:19.788] {
[16:25:19.788] {
[16:25:19.788] {
[16:25:19.788] base::local({
[16:25:19.788] has_future <- base::requireNamespace("future",
[16:25:19.788] quietly = TRUE)
[16:25:19.788] if (has_future) {
[16:25:19.788] ns <- base::getNamespace("future")
[16:25:19.788] version <- ns[[".package"]][["version"]]
[16:25:19.788] if (is.null(version))
[16:25:19.788] version <- utils::packageVersion("future")
[16:25:19.788] }
[16:25:19.788] else {
[16:25:19.788] version <- NULL
[16:25:19.788] }
[16:25:19.788] if (!has_future || version < "1.8.0") {
[16:25:19.788] info <- base::c(r_version = base::gsub("R version ",
[16:25:19.788] "", base::R.version$version.string),
[16:25:19.788] platform = base::sprintf("%s (%s-bit)",
[16:25:19.788] base::R.version$platform, 8 * base::.Machine$sizeof.pointer),
[16:25:19.788] os = base::paste(base::Sys.info()[base::c("sysname",
[16:25:19.788] "release", "version")], collapse = " "),
[16:25:19.788] hostname = base::Sys.info()[["nodename"]])
[16:25:19.788] info <- base::sprintf("%s: %s", base::names(info),
[16:25:19.788] info)
[16:25:19.788] info <- base::paste(info, collapse = "; ")
[16:25:19.788] if (!has_future) {
[16:25:19.788] msg <- base::sprintf("Package 'future' is not installed on worker (%s)",
[16:25:19.788] info)
[16:25:19.788] }
[16:25:19.788] else {
[16:25:19.788] msg <- base::sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s",
[16:25:19.788] info, version)
[16:25:19.788] }
[16:25:19.788] base::stop(msg)
[16:25:19.788] }
[16:25:19.788] })
[16:25:19.788] }
[16:25:19.788] ...future.strategy.old <- future::plan("list")
[16:25:19.788] options(future.plan = NULL)
[16:25:19.788] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:19.788] future::plan("default", .cleanup = FALSE, .init = FALSE)
[16:25:19.788] }
[16:25:19.788] ...future.workdir <- getwd()
[16:25:19.788] }
[16:25:19.788] ...future.oldOptions <- base::as.list(base::.Options)
[16:25:19.788] ...future.oldEnvVars <- base::Sys.getenv()
[16:25:19.788] }
[16:25:19.788] base::options(future.startup.script = FALSE, future.globals.onMissing = NULL,
[16:25:19.788] future.globals.maxSize = NULL, future.globals.method = NULL,
[16:25:19.788] future.globals.onMissing = NULL, future.globals.onReference = NULL,
[16:25:19.788] future.globals.resolve = NULL, future.resolve.recursive = NULL,
[16:25:19.788] future.rng.onMisuse = NULL, future.rng.onMisuse.keepFuture = NULL,
[16:25:19.788] future.stdout.windows.reencode = NULL, width = 80L)
[16:25:19.788] ...future.futureOptionsAdded <- base::setdiff(base::names(base::.Options),
[16:25:19.788] base::names(...future.oldOptions))
[16:25:19.788] }
[16:25:19.788] if (FALSE) {
[16:25:19.788] }
[16:25:19.788] else {
[16:25:19.788] if (TRUE) {
[16:25:19.788] ...future.stdout <- base::rawConnection(base::raw(0L),
[16:25:19.788] open = "w")
[16:25:19.788] }
[16:25:19.788] else {
[16:25:19.788] ...future.stdout <- base::file(base::switch(.Platform$OS.type,
[16:25:19.788] windows = "NUL", "/dev/null"), open = "w")
[16:25:19.788] }
[16:25:19.788] base::sink(...future.stdout, type = "output", split = FALSE)
[16:25:19.788] base::on.exit(if (!base::is.null(...future.stdout)) {
[16:25:19.788] base::sink(type = "output", split = FALSE)
[16:25:19.788] base::close(...future.stdout)
[16:25:19.788] }, add = TRUE)
[16:25:19.788] }
[16:25:19.788] ...future.frame <- base::sys.nframe()
[16:25:19.788] ...future.conditions <- base::list()
[16:25:19.788] ...future.rng <- base::globalenv()$.Random.seed
[16:25:19.788] if (FALSE) {
[16:25:19.788] ...future.globalenv.names <- c(base::names(base::.GlobalEnv),
[16:25:19.788] "...future.value", "...future.globalenv.names", ".Random.seed")
[16:25:19.788] }
[16:25:19.788] ...future.result <- base::tryCatch({
[16:25:19.788] base::withCallingHandlers({
[16:25:19.788] ...future.value <- base::withVisible(base::local(NA))
[16:25:19.788] future::FutureResult(value = ...future.value$value,
[16:25:19.788] visible = ...future.value$visible, rng = !identical(base::globalenv()$.Random.seed,
[16:25:19.788] ...future.rng), globalenv = if (FALSE)
[16:25:19.788] list(added = base::setdiff(base::names(base::.GlobalEnv),
[16:25:19.788] ...future.globalenv.names))
[16:25:19.788] else NULL, started = ...future.startTime, version = "1.8")
[16:25:19.788] }, condition = base::local({
[16:25:19.788] c <- base::c
[16:25:19.788] inherits <- base::inherits
[16:25:19.788] invokeRestart <- base::invokeRestart
[16:25:19.788] length <- base::length
[16:25:19.788] list <- base::list
[16:25:19.788] seq.int <- base::seq.int
[16:25:19.788] signalCondition <- base::signalCondition
[16:25:19.788] sys.calls <- base::sys.calls
[16:25:19.788] `[[` <- base::`[[`
[16:25:19.788] `+` <- base::`+`
[16:25:19.788] `<<-` <- base::`<<-`
[16:25:19.788] sysCalls <- function(calls = sys.calls(), from = 1L) {
[16:25:19.788] calls[seq.int(from = from + 12L, to = length(calls) -
[16:25:19.788] 3L)]
[16:25:19.788] }
[16:25:19.788] function(cond) {
[16:25:19.788] is_error <- inherits(cond, "error")
[16:25:19.788] ignore <- !is_error && !is.null(NULL) && inherits(cond,
[16:25:19.788] NULL)
[16:25:19.788] if (is_error) {
[16:25:19.788] sessionInformation <- function() {
[16:25:19.788] list(r = base::R.Version(), locale = base::Sys.getlocale(),
[16:25:19.788] rngkind = base::RNGkind(), namespaces = base::loadedNamespaces(),
[16:25:19.788] search = base::search(), system = base::Sys.info())
[16:25:19.788] }
[16:25:19.788] ...future.conditions[[length(...future.conditions) +
[16:25:19.788] 1L]] <<- list(condition = cond, calls = c(sysCalls(from = ...future.frame),
[16:25:19.788] cond$call), session = sessionInformation(),
[16:25:19.788] timestamp = base::Sys.time(), signaled = 0L)
[16:25:19.788] signalCondition(cond)
[16:25:19.788] }
[16:25:19.788] else if (!ignore && TRUE && inherits(cond, "condition")) {
[16:25:19.788] signal <- FALSE && inherits(cond, character(0))
[16:25:19.788] ...future.conditions[[length(...future.conditions) +
[16:25:19.788] 1L]] <<- list(condition = cond, signaled = base::as.integer(signal))
[16:25:19.788] if (FALSE && !signal) {
[16:25:19.788] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:19.788] {
[16:25:19.788] inherits <- base::inherits
[16:25:19.788] invokeRestart <- base::invokeRestart
[16:25:19.788] is.null <- base::is.null
[16:25:19.788] muffled <- FALSE
[16:25:19.788] if (inherits(cond, "message")) {
[16:25:19.788] muffled <- grepl(pattern, "muffleMessage")
[16:25:19.788] if (muffled)
[16:25:19.788] invokeRestart("muffleMessage")
[16:25:19.788] }
[16:25:19.788] else if (inherits(cond, "warning")) {
[16:25:19.788] muffled <- grepl(pattern, "muffleWarning")
[16:25:19.788] if (muffled)
[16:25:19.788] invokeRestart("muffleWarning")
[16:25:19.788] }
[16:25:19.788] else if (inherits(cond, "condition")) {
[16:25:19.788] if (!is.null(pattern)) {
[16:25:19.788] computeRestarts <- base::computeRestarts
[16:25:19.788] grepl <- base::grepl
[16:25:19.788] restarts <- computeRestarts(cond)
[16:25:19.788] for (restart in restarts) {
[16:25:19.788] name <- restart$name
[16:25:19.788] if (is.null(name))
[16:25:19.788] next
[16:25:19.788] if (!grepl(pattern, name))
[16:25:19.788] next
[16:25:19.788] invokeRestart(restart)
[16:25:19.788] muffled <- TRUE
[16:25:19.788] break
[16:25:19.788] }
[16:25:19.788] }
[16:25:19.788] }
[16:25:19.788] invisible(muffled)
[16:25:19.788] }
[16:25:19.788] muffleCondition(cond, pattern = "^muffle")
[16:25:19.788] }
[16:25:19.788] }
[16:25:19.788] else {
[16:25:19.788] if (TRUE) {
[16:25:19.788] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:19.788] {
[16:25:19.788] inherits <- base::inherits
[16:25:19.788] invokeRestart <- base::invokeRestart
[16:25:19.788] is.null <- base::is.null
[16:25:19.788] muffled <- FALSE
[16:25:19.788] if (inherits(cond, "message")) {
[16:25:19.788] muffled <- grepl(pattern, "muffleMessage")
[16:25:19.788] if (muffled)
[16:25:19.788] invokeRestart("muffleMessage")
[16:25:19.788] }
[16:25:19.788] else if (inherits(cond, "warning")) {
[16:25:19.788] muffled <- grepl(pattern, "muffleWarning")
[16:25:19.788] if (muffled)
[16:25:19.788] invokeRestart("muffleWarning")
[16:25:19.788] }
[16:25:19.788] else if (inherits(cond, "condition")) {
[16:25:19.788] if (!is.null(pattern)) {
[16:25:19.788] computeRestarts <- base::computeRestarts
[16:25:19.788] grepl <- base::grepl
[16:25:19.788] restarts <- computeRestarts(cond)
[16:25:19.788] for (restart in restarts) {
[16:25:19.788] name <- restart$name
[16:25:19.788] if (is.null(name))
[16:25:19.788] next
[16:25:19.788] if (!grepl(pattern, name))
[16:25:19.788] next
[16:25:19.788] invokeRestart(restart)
[16:25:19.788] muffled <- TRUE
[16:25:19.788] break
[16:25:19.788] }
[16:25:19.788] }
[16:25:19.788] }
[16:25:19.788] invisible(muffled)
[16:25:19.788] }
[16:25:19.788] muffleCondition(cond, pattern = "^muffle")
[16:25:19.788] }
[16:25:19.788] }
[16:25:19.788] }
[16:25:19.788] }))
[16:25:19.788] }, error = function(ex) {
[16:25:19.788] base::structure(base::list(value = NULL, visible = NULL,
[16:25:19.788] conditions = ...future.conditions, rng = !identical(base::globalenv()$.Random.seed,
[16:25:19.788] ...future.rng), started = ...future.startTime,
[16:25:19.788] finished = Sys.time(), session_uuid = NA_character_,
[16:25:19.788] version = "1.8"), class = "FutureResult")
[16:25:19.788] }, finally = {
[16:25:19.788] if (!identical(...future.workdir, getwd()))
[16:25:19.788] setwd(...future.workdir)
[16:25:19.788] {
[16:25:19.788] if (identical(getOption("nwarnings"), ...future.oldOptions$nwarnings)) {
[16:25:19.788] ...future.oldOptions$nwarnings <- NULL
[16:25:19.788] }
[16:25:19.788] base::options(...future.oldOptions)
[16:25:19.788] if (.Platform$OS.type == "windows") {
[16:25:19.788] old_names <- names(...future.oldEnvVars)
[16:25:19.788] envs <- base::Sys.getenv()
[16:25:19.788] names <- names(envs)
[16:25:19.788] common <- intersect(names, old_names)
[16:25:19.788] added <- setdiff(names, old_names)
[16:25:19.788] removed <- setdiff(old_names, names)
[16:25:19.788] changed <- common[...future.oldEnvVars[common] !=
[16:25:19.788] envs[common]]
[16:25:19.788] NAMES <- toupper(changed)
[16:25:19.788] args <- list()
[16:25:19.788] for (kk in seq_along(NAMES)) {
[16:25:19.788] name <- changed[[kk]]
[16:25:19.788] NAME <- NAMES[[kk]]
[16:25:19.788] if (name != NAME && is.element(NAME, old_names))
[16:25:19.788] next
[16:25:19.788] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:19.788] }
[16:25:19.788] NAMES <- toupper(added)
[16:25:19.788] for (kk in seq_along(NAMES)) {
[16:25:19.788] name <- added[[kk]]
[16:25:19.788] NAME <- NAMES[[kk]]
[16:25:19.788] if (name != NAME && is.element(NAME, old_names))
[16:25:19.788] next
[16:25:19.788] args[[name]] <- ""
[16:25:19.788] }
[16:25:19.788] NAMES <- toupper(removed)
[16:25:19.788] for (kk in seq_along(NAMES)) {
[16:25:19.788] name <- removed[[kk]]
[16:25:19.788] NAME <- NAMES[[kk]]
[16:25:19.788] if (name != NAME && is.element(NAME, old_names))
[16:25:19.788] next
[16:25:19.788] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:19.788] }
[16:25:19.788] if (length(args) > 0)
[16:25:19.788] base::do.call(base::Sys.setenv, args = args)
[16:25:19.788] args <- names <- old_names <- NAMES <- envs <- common <- added <- removed <- NULL
[16:25:19.788] }
[16:25:19.788] else {
[16:25:19.788] base::do.call(base::Sys.setenv, args = base::as.list(...future.oldEnvVars))
[16:25:19.788] }
[16:25:19.788] {
[16:25:19.788] if (base::length(...future.futureOptionsAdded) >
[16:25:19.788] 0L) {
[16:25:19.788] opts <- base::vector("list", length = base::length(...future.futureOptionsAdded))
[16:25:19.788] base::names(opts) <- ...future.futureOptionsAdded
[16:25:19.788] base::options(opts)
[16:25:19.788] }
[16:25:19.788] {
[16:25:19.788] NULL
[16:25:19.788] options(future.plan = NULL)
[16:25:19.788] if (is.na(NA_character_))
[16:25:19.788] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:19.788] else Sys.setenv(R_FUTURE_PLAN = NA_character_)
[16:25:19.788] future::plan(...future.strategy.old, .cleanup = FALSE,
[16:25:19.788] .init = FALSE)
[16:25:19.788] }
[16:25:19.788] }
[16:25:19.788] }
[16:25:19.788] })
[16:25:19.788] if (TRUE) {
[16:25:19.788] base::sink(type = "output", split = FALSE)
[16:25:19.788] if (TRUE) {
[16:25:19.788] ...future.result$stdout <- base::rawToChar(base::rawConnectionValue(...future.stdout))
[16:25:19.788] }
[16:25:19.788] else {
[16:25:19.788] ...future.result["stdout"] <- base::list(NULL)
[16:25:19.788] }
[16:25:19.788] base::close(...future.stdout)
[16:25:19.788] ...future.stdout <- NULL
[16:25:19.788] }
[16:25:19.788] ...future.result$conditions <- ...future.conditions
[16:25:19.788] ...future.result$finished <- base::Sys.time()
[16:25:19.788] ...future.result
[16:25:19.788] }
[16:25:19.952] plan(): plan_init() of 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function' ... DONE
[16:25:19.953] plan(): nbrOfWorkers() = 2
>
> message("*** plan() ...")
*** plan() ...
>
> message("*** future::plan(future.mirai::mirai_multisession)")
*** future::plan(future.mirai::mirai_multisession)
> oplan <- future::plan(future.mirai::mirai_multisession)
[16:25:19.954] plan(): Setting new future strategy stack:
[16:25:19.954] List of future strategies:
[16:25:19.954] 1. mirai_multisession:
[16:25:19.954] - args: function (expr, substitute = TRUE, envir = parent.frame(), ..., workers = availableCores())
[16:25:19.954] - tweaked: FALSE
[16:25:19.954] - call: future::plan(future.mirai::mirai_multisession)
[16:25:19.972] plan(): plan_init() of 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function' ...
[16:25:19.972] < mirai | $data >
[16:25:19.974] getGlobalsAndPackages() ...
[16:25:19.974] Not searching for globals
[16:25:19.974] - globals: [0] <none>
[16:25:19.975] getGlobalsAndPackages() ... DONE
[16:25:19.975] getGlobalsAndPackages() ...
[16:25:19.975]
[16:25:19.975] - globals: [0] <none>
[16:25:19.975] getGlobalsAndPackages() ... DONE
[16:25:19.976] Packages needed by the future expression (n = 0): <none>
[16:25:19.976] Packages needed by future strategies (n = 0): <none>
[16:25:19.977] {
[16:25:19.977] {
[16:25:19.977] {
[16:25:19.977] ...future.startTime <- base::Sys.time()
[16:25:19.977] {
[16:25:19.977] {
[16:25:19.977] {
[16:25:19.977] base::local({
[16:25:19.977] has_future <- base::requireNamespace("future",
[16:25:19.977] quietly = TRUE)
[16:25:19.977] if (has_future) {
[16:25:19.977] ns <- base::getNamespace("future")
[16:25:19.977] version <- ns[[".package"]][["version"]]
[16:25:19.977] if (is.null(version))
[16:25:19.977] version <- utils::packageVersion("future")
[16:25:19.977] }
[16:25:19.977] else {
[16:25:19.977] version <- NULL
[16:25:19.977] }
[16:25:19.977] if (!has_future || version < "1.8.0") {
[16:25:19.977] info <- base::c(r_version = base::gsub("R version ",
[16:25:19.977] "", base::R.version$version.string),
[16:25:19.977] platform = base::sprintf("%s (%s-bit)",
[16:25:19.977] base::R.version$platform, 8 * base::.Machine$sizeof.pointer),
[16:25:19.977] os = base::paste(base::Sys.info()[base::c("sysname",
[16:25:19.977] "release", "version")], collapse = " "),
[16:25:19.977] hostname = base::Sys.info()[["nodename"]])
[16:25:19.977] info <- base::sprintf("%s: %s", base::names(info),
[16:25:19.977] info)
[16:25:19.977] info <- base::paste(info, collapse = "; ")
[16:25:19.977] if (!has_future) {
[16:25:19.977] msg <- base::sprintf("Package 'future' is not installed on worker (%s)",
[16:25:19.977] info)
[16:25:19.977] }
[16:25:19.977] else {
[16:25:19.977] msg <- base::sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s",
[16:25:19.977] info, version)
[16:25:19.977] }
[16:25:19.977] base::stop(msg)
[16:25:19.977] }
[16:25:19.977] })
[16:25:19.977] }
[16:25:19.977] ...future.strategy.old <- future::plan("list")
[16:25:19.977] options(future.plan = NULL)
[16:25:19.977] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:19.977] future::plan("default", .cleanup = FALSE, .init = FALSE)
[16:25:19.977] }
[16:25:19.977] ...future.workdir <- getwd()
[16:25:19.977] }
[16:25:19.977] ...future.oldOptions <- base::as.list(base::.Options)
[16:25:19.977] ...future.oldEnvVars <- base::Sys.getenv()
[16:25:19.977] }
[16:25:19.977] base::options(future.startup.script = FALSE, future.globals.onMissing = NULL,
[16:25:19.977] future.globals.maxSize = NULL, future.globals.method = NULL,
[16:25:19.977] future.globals.onMissing = NULL, future.globals.onReference = NULL,
[16:25:19.977] future.globals.resolve = NULL, future.resolve.recursive = NULL,
[16:25:19.977] future.rng.onMisuse = NULL, future.rng.onMisuse.keepFuture = NULL,
[16:25:19.977] future.stdout.windows.reencode = NULL, width = 80L)
[16:25:19.977] ...future.futureOptionsAdded <- base::setdiff(base::names(base::.Options),
[16:25:19.977] base::names(...future.oldOptions))
[16:25:19.977] }
[16:25:19.977] if (FALSE) {
[16:25:19.977] }
[16:25:19.977] else {
[16:25:19.977] if (TRUE) {
[16:25:19.977] ...future.stdout <- base::rawConnection(base::raw(0L),
[16:25:19.977] open = "w")
[16:25:19.977] }
[16:25:19.977] else {
[16:25:19.977] ...future.stdout <- base::file(base::switch(.Platform$OS.type,
[16:25:19.977] windows = "NUL", "/dev/null"), open = "w")
[16:25:19.977] }
[16:25:19.977] base::sink(...future.stdout, type = "output", split = FALSE)
[16:25:19.977] base::on.exit(if (!base::is.null(...future.stdout)) {
[16:25:19.977] base::sink(type = "output", split = FALSE)
[16:25:19.977] base::close(...future.stdout)
[16:25:19.977] }, add = TRUE)
[16:25:19.977] }
[16:25:19.977] ...future.frame <- base::sys.nframe()
[16:25:19.977] ...future.conditions <- base::list()
[16:25:19.977] ...future.rng <- base::globalenv()$.Random.seed
[16:25:19.977] if (FALSE) {
[16:25:19.977] ...future.globalenv.names <- c(base::names(base::.GlobalEnv),
[16:25:19.977] "...future.value", "...future.globalenv.names", ".Random.seed")
[16:25:19.977] }
[16:25:19.977] ...future.result <- base::tryCatch({
[16:25:19.977] base::withCallingHandlers({
[16:25:19.977] ...future.value <- base::withVisible(base::local(NA))
[16:25:19.977] future::FutureResult(value = ...future.value$value,
[16:25:19.977] visible = ...future.value$visible, rng = !identical(base::globalenv()$.Random.seed,
[16:25:19.977] ...future.rng), globalenv = if (FALSE)
[16:25:19.977] list(added = base::setdiff(base::names(base::.GlobalEnv),
[16:25:19.977] ...future.globalenv.names))
[16:25:19.977] else NULL, started = ...future.startTime, version = "1.8")
[16:25:19.977] }, condition = base::local({
[16:25:19.977] c <- base::c
[16:25:19.977] inherits <- base::inherits
[16:25:19.977] invokeRestart <- base::invokeRestart
[16:25:19.977] length <- base::length
[16:25:19.977] list <- base::list
[16:25:19.977] seq.int <- base::seq.int
[16:25:19.977] signalCondition <- base::signalCondition
[16:25:19.977] sys.calls <- base::sys.calls
[16:25:19.977] `[[` <- base::`[[`
[16:25:19.977] `+` <- base::`+`
[16:25:19.977] `<<-` <- base::`<<-`
[16:25:19.977] sysCalls <- function(calls = sys.calls(), from = 1L) {
[16:25:19.977] calls[seq.int(from = from + 12L, to = length(calls) -
[16:25:19.977] 3L)]
[16:25:19.977] }
[16:25:19.977] function(cond) {
[16:25:19.977] is_error <- inherits(cond, "error")
[16:25:19.977] ignore <- !is_error && !is.null(NULL) && inherits(cond,
[16:25:19.977] NULL)
[16:25:19.977] if (is_error) {
[16:25:19.977] sessionInformation <- function() {
[16:25:19.977] list(r = base::R.Version(), locale = base::Sys.getlocale(),
[16:25:19.977] rngkind = base::RNGkind(), namespaces = base::loadedNamespaces(),
[16:25:19.977] search = base::search(), system = base::Sys.info())
[16:25:19.977] }
[16:25:19.977] ...future.conditions[[length(...future.conditions) +
[16:25:19.977] 1L]] <<- list(condition = cond, calls = c(sysCalls(from = ...future.frame),
[16:25:19.977] cond$call), session = sessionInformation(),
[16:25:19.977] timestamp = base::Sys.time(), signaled = 0L)
[16:25:19.977] signalCondition(cond)
[16:25:19.977] }
[16:25:19.977] else if (!ignore && TRUE && inherits(cond, "condition")) {
[16:25:19.977] signal <- FALSE && inherits(cond, character(0))
[16:25:19.977] ...future.conditions[[length(...future.conditions) +
[16:25:19.977] 1L]] <<- list(condition = cond, signaled = base::as.integer(signal))
[16:25:19.977] if (FALSE && !signal) {
[16:25:19.977] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:19.977] {
[16:25:19.977] inherits <- base::inherits
[16:25:19.977] invokeRestart <- base::invokeRestart
[16:25:19.977] is.null <- base::is.null
[16:25:19.977] muffled <- FALSE
[16:25:19.977] if (inherits(cond, "message")) {
[16:25:19.977] muffled <- grepl(pattern, "muffleMessage")
[16:25:19.977] if (muffled)
[16:25:19.977] invokeRestart("muffleMessage")
[16:25:19.977] }
[16:25:19.977] else if (inherits(cond, "warning")) {
[16:25:19.977] muffled <- grepl(pattern, "muffleWarning")
[16:25:19.977] if (muffled)
[16:25:19.977] invokeRestart("muffleWarning")
[16:25:19.977] }
[16:25:19.977] else if (inherits(cond, "condition")) {
[16:25:19.977] if (!is.null(pattern)) {
[16:25:19.977] computeRestarts <- base::computeRestarts
[16:25:19.977] grepl <- base::grepl
[16:25:19.977] restarts <- computeRestarts(cond)
[16:25:19.977] for (restart in restarts) {
[16:25:19.977] name <- restart$name
[16:25:19.977] if (is.null(name))
[16:25:19.977] next
[16:25:19.977] if (!grepl(pattern, name))
[16:25:19.977] next
[16:25:19.977] invokeRestart(restart)
[16:25:19.977] muffled <- TRUE
[16:25:19.977] break
[16:25:19.977] }
[16:25:19.977] }
[16:25:19.977] }
[16:25:19.977] invisible(muffled)
[16:25:19.977] }
[16:25:19.977] muffleCondition(cond, pattern = "^muffle")
[16:25:19.977] }
[16:25:19.977] }
[16:25:19.977] else {
[16:25:19.977] if (TRUE) {
[16:25:19.977] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:19.977] {
[16:25:19.977] inherits <- base::inherits
[16:25:19.977] invokeRestart <- base::invokeRestart
[16:25:19.977] is.null <- base::is.null
[16:25:19.977] muffled <- FALSE
[16:25:19.977] if (inherits(cond, "message")) {
[16:25:19.977] muffled <- grepl(pattern, "muffleMessage")
[16:25:19.977] if (muffled)
[16:25:19.977] invokeRestart("muffleMessage")
[16:25:19.977] }
[16:25:19.977] else if (inherits(cond, "warning")) {
[16:25:19.977] muffled <- grepl(pattern, "muffleWarning")
[16:25:19.977] if (muffled)
[16:25:19.977] invokeRestart("muffleWarning")
[16:25:19.977] }
[16:25:19.977] else if (inherits(cond, "condition")) {
[16:25:19.977] if (!is.null(pattern)) {
[16:25:19.977] computeRestarts <- base::computeRestarts
[16:25:19.977] grepl <- base::grepl
[16:25:19.977] restarts <- computeRestarts(cond)
[16:25:19.977] for (restart in restarts) {
[16:25:19.977] name <- restart$name
[16:25:19.977] if (is.null(name))
[16:25:19.977] next
[16:25:19.977] if (!grepl(pattern, name))
[16:25:19.977] next
[16:25:19.977] invokeRestart(restart)
[16:25:19.977] muffled <- TRUE
[16:25:19.977] break
[16:25:19.977] }
[16:25:19.977] }
[16:25:19.977] }
[16:25:19.977] invisible(muffled)
[16:25:19.977] }
[16:25:19.977] muffleCondition(cond, pattern = "^muffle")
[16:25:19.977] }
[16:25:19.977] }
[16:25:19.977] }
[16:25:19.977] }))
[16:25:19.977] }, error = function(ex) {
[16:25:19.977] base::structure(base::list(value = NULL, visible = NULL,
[16:25:19.977] conditions = ...future.conditions, rng = !identical(base::globalenv()$.Random.seed,
[16:25:19.977] ...future.rng), started = ...future.startTime,
[16:25:19.977] finished = Sys.time(), session_uuid = NA_character_,
[16:25:19.977] version = "1.8"), class = "FutureResult")
[16:25:19.977] }, finally = {
[16:25:19.977] if (!identical(...future.workdir, getwd()))
[16:25:19.977] setwd(...future.workdir)
[16:25:19.977] {
[16:25:19.977] if (identical(getOption("nwarnings"), ...future.oldOptions$nwarnings)) {
[16:25:19.977] ...future.oldOptions$nwarnings <- NULL
[16:25:19.977] }
[16:25:19.977] base::options(...future.oldOptions)
[16:25:19.977] if (.Platform$OS.type == "windows") {
[16:25:19.977] old_names <- names(...future.oldEnvVars)
[16:25:19.977] envs <- base::Sys.getenv()
[16:25:19.977] names <- names(envs)
[16:25:19.977] common <- intersect(names, old_names)
[16:25:19.977] added <- setdiff(names, old_names)
[16:25:19.977] removed <- setdiff(old_names, names)
[16:25:19.977] changed <- common[...future.oldEnvVars[common] !=
[16:25:19.977] envs[common]]
[16:25:19.977] NAMES <- toupper(changed)
[16:25:19.977] args <- list()
[16:25:19.977] for (kk in seq_along(NAMES)) {
[16:25:19.977] name <- changed[[kk]]
[16:25:19.977] NAME <- NAMES[[kk]]
[16:25:19.977] if (name != NAME && is.element(NAME, old_names))
[16:25:19.977] next
[16:25:19.977] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:19.977] }
[16:25:19.977] NAMES <- toupper(added)
[16:25:19.977] for (kk in seq_along(NAMES)) {
[16:25:19.977] name <- added[[kk]]
[16:25:19.977] NAME <- NAMES[[kk]]
[16:25:19.977] if (name != NAME && is.element(NAME, old_names))
[16:25:19.977] next
[16:25:19.977] args[[name]] <- ""
[16:25:19.977] }
[16:25:19.977] NAMES <- toupper(removed)
[16:25:19.977] for (kk in seq_along(NAMES)) {
[16:25:19.977] name <- removed[[kk]]
[16:25:19.977] NAME <- NAMES[[kk]]
[16:25:19.977] if (name != NAME && is.element(NAME, old_names))
[16:25:19.977] next
[16:25:19.977] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:19.977] }
[16:25:19.977] if (length(args) > 0)
[16:25:19.977] base::do.call(base::Sys.setenv, args = args)
[16:25:19.977] args <- names <- old_names <- NAMES <- envs <- common <- added <- removed <- NULL
[16:25:19.977] }
[16:25:19.977] else {
[16:25:19.977] base::do.call(base::Sys.setenv, args = base::as.list(...future.oldEnvVars))
[16:25:19.977] }
[16:25:19.977] {
[16:25:19.977] if (base::length(...future.futureOptionsAdded) >
[16:25:19.977] 0L) {
[16:25:19.977] opts <- base::vector("list", length = base::length(...future.futureOptionsAdded))
[16:25:19.977] base::names(opts) <- ...future.futureOptionsAdded
[16:25:19.977] base::options(opts)
[16:25:19.977] }
[16:25:19.977] {
[16:25:19.977] NULL
[16:25:19.977] options(future.plan = NULL)
[16:25:19.977] if (is.na(NA_character_))
[16:25:19.977] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:19.977] else Sys.setenv(R_FUTURE_PLAN = NA_character_)
[16:25:19.977] future::plan(...future.strategy.old, .cleanup = FALSE,
[16:25:19.977] .init = FALSE)
[16:25:19.977] }
[16:25:19.977] }
[16:25:19.977] }
[16:25:19.977] })
[16:25:19.977] if (TRUE) {
[16:25:19.977] base::sink(type = "output", split = FALSE)
[16:25:19.977] if (TRUE) {
[16:25:19.977] ...future.result$stdout <- base::rawToChar(base::rawConnectionValue(...future.stdout))
[16:25:19.977] }
[16:25:19.977] else {
[16:25:19.977] ...future.result["stdout"] <- base::list(NULL)
[16:25:19.977] }
[16:25:19.977] base::close(...future.stdout)
[16:25:19.977] ...future.stdout <- NULL
[16:25:19.977] }
[16:25:19.977] ...future.result$conditions <- ...future.conditions
[16:25:19.977] ...future.result$finished <- base::Sys.time()
[16:25:19.977] ...future.result
[16:25:19.977] }
[16:25:20.129] plan(): plan_init() of 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function' ... DONE
[16:25:20.129] plan(): nbrOfWorkers() = 2
> print(future::plan())
mirai_multisession:
- args: function (expr, substitute = TRUE, envir = parent.frame(), ..., workers = availableCores())
- tweaked: FALSE
- call: future::plan(future.mirai::mirai_multisession)
> future::plan(oplan)
[16:25:20.133] plan(): Setting new future strategy stack:
[16:25:20.133] List of future strategies:
[16:25:20.133] 1. mirai_multisession:
[16:25:20.133] - args: function (expr, substitute = TRUE, envir = parent.frame(), ..., workers = availableCores())
[16:25:20.133] - tweaked: FALSE
[16:25:20.133] - call: future::plan(future.mirai::mirai_multisession)
[16:25:20.134] plan(): nbrOfWorkers() = 2
> print(future::plan())
mirai_multisession:
- args: function (expr, substitute = TRUE, envir = parent.frame(), ..., workers = availableCores())
- tweaked: FALSE
- call: future::plan(future.mirai::mirai_multisession)
>
>
> library("future.mirai")
Loading required package: future
[16:25:20.145] Option 'future.startup.script': TRUE
[16:25:20.145] Future startup scripts considered: '.future.R', '~/.future.R'
[16:25:20.146] Future startup scripts found: <none>
> plan(mirai_multisession)
[16:25:20.149] plan(): Setting new future strategy stack:
[16:25:20.149] List of future strategies:
[16:25:20.149] 1. mirai_multisession:
[16:25:20.149] - args: function (expr, substitute = TRUE, envir = parent.frame(), ..., workers = availableCores())
[16:25:20.149] - tweaked: FALSE
[16:25:20.149] - call: plan(mirai_multisession)
[16:25:20.150] plan(): plan_init() of 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function' ...
[16:25:20.150] < mirai | $data >
[16:25:20.153] getGlobalsAndPackages() ...
[16:25:20.153] Not searching for globals
[16:25:20.154] - globals: [0] <none>
[16:25:20.154] getGlobalsAndPackages() ... DONE
[16:25:20.154] getGlobalsAndPackages() ...
[16:25:20.154]
[16:25:20.155] - globals: [0] <none>
[16:25:20.155] getGlobalsAndPackages() ... DONE
[16:25:20.155] Packages needed by the future expression (n = 0): <none>
[16:25:20.156] Packages needed by future strategies (n = 0): <none>
[16:25:20.157] {
[16:25:20.157] {
[16:25:20.157] {
[16:25:20.157] ...future.startTime <- base::Sys.time()
[16:25:20.157] {
[16:25:20.157] {
[16:25:20.157] {
[16:25:20.157] base::local({
[16:25:20.157] has_future <- base::requireNamespace("future",
[16:25:20.157] quietly = TRUE)
[16:25:20.157] if (has_future) {
[16:25:20.157] ns <- base::getNamespace("future")
[16:25:20.157] version <- ns[[".package"]][["version"]]
[16:25:20.157] if (is.null(version))
[16:25:20.157] version <- utils::packageVersion("future")
[16:25:20.157] }
[16:25:20.157] else {
[16:25:20.157] version <- NULL
[16:25:20.157] }
[16:25:20.157] if (!has_future || version < "1.8.0") {
[16:25:20.157] info <- base::c(r_version = base::gsub("R version ",
[16:25:20.157] "", base::R.version$version.string),
[16:25:20.157] platform = base::sprintf("%s (%s-bit)",
[16:25:20.157] base::R.version$platform, 8 * base::.Machine$sizeof.pointer),
[16:25:20.157] os = base::paste(base::Sys.info()[base::c("sysname",
[16:25:20.157] "release", "version")], collapse = " "),
[16:25:20.157] hostname = base::Sys.info()[["nodename"]])
[16:25:20.157] info <- base::sprintf("%s: %s", base::names(info),
[16:25:20.157] info)
[16:25:20.157] info <- base::paste(info, collapse = "; ")
[16:25:20.157] if (!has_future) {
[16:25:20.157] msg <- base::sprintf("Package 'future' is not installed on worker (%s)",
[16:25:20.157] info)
[16:25:20.157] }
[16:25:20.157] else {
[16:25:20.157] msg <- base::sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s",
[16:25:20.157] info, version)
[16:25:20.157] }
[16:25:20.157] base::stop(msg)
[16:25:20.157] }
[16:25:20.157] })
[16:25:20.157] }
[16:25:20.157] ...future.strategy.old <- future::plan("list")
[16:25:20.157] options(future.plan = NULL)
[16:25:20.157] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:20.157] future::plan("default", .cleanup = FALSE, .init = FALSE)
[16:25:20.157] }
[16:25:20.157] ...future.workdir <- getwd()
[16:25:20.157] }
[16:25:20.157] ...future.oldOptions <- base::as.list(base::.Options)
[16:25:20.157] ...future.oldEnvVars <- base::Sys.getenv()
[16:25:20.157] }
[16:25:20.157] base::options(future.startup.script = FALSE, future.globals.onMissing = NULL,
[16:25:20.157] future.globals.maxSize = NULL, future.globals.method = NULL,
[16:25:20.157] future.globals.onMissing = NULL, future.globals.onReference = NULL,
[16:25:20.157] future.globals.resolve = NULL, future.resolve.recursive = NULL,
[16:25:20.157] future.rng.onMisuse = NULL, future.rng.onMisuse.keepFuture = NULL,
[16:25:20.157] future.stdout.windows.reencode = NULL, width = 80L)
[16:25:20.157] ...future.futureOptionsAdded <- base::setdiff(base::names(base::.Options),
[16:25:20.157] base::names(...future.oldOptions))
[16:25:20.157] }
[16:25:20.157] if (FALSE) {
[16:25:20.157] }
[16:25:20.157] else {
[16:25:20.157] if (TRUE) {
[16:25:20.157] ...future.stdout <- base::rawConnection(base::raw(0L),
[16:25:20.157] open = "w")
[16:25:20.157] }
[16:25:20.157] else {
[16:25:20.157] ...future.stdout <- base::file(base::switch(.Platform$OS.type,
[16:25:20.157] windows = "NUL", "/dev/null"), open = "w")
[16:25:20.157] }
[16:25:20.157] base::sink(...future.stdout, type = "output", split = FALSE)
[16:25:20.157] base::on.exit(if (!base::is.null(...future.stdout)) {
[16:25:20.157] base::sink(type = "output", split = FALSE)
[16:25:20.157] base::close(...future.stdout)
[16:25:20.157] }, add = TRUE)
[16:25:20.157] }
[16:25:20.157] ...future.frame <- base::sys.nframe()
[16:25:20.157] ...future.conditions <- base::list()
[16:25:20.157] ...future.rng <- base::globalenv()$.Random.seed
[16:25:20.157] if (FALSE) {
[16:25:20.157] ...future.globalenv.names <- c(base::names(base::.GlobalEnv),
[16:25:20.157] "...future.value", "...future.globalenv.names", ".Random.seed")
[16:25:20.157] }
[16:25:20.157] ...future.result <- base::tryCatch({
[16:25:20.157] base::withCallingHandlers({
[16:25:20.157] ...future.value <- base::withVisible(base::local(NA))
[16:25:20.157] future::FutureResult(value = ...future.value$value,
[16:25:20.157] visible = ...future.value$visible, rng = !identical(base::globalenv()$.Random.seed,
[16:25:20.157] ...future.rng), globalenv = if (FALSE)
[16:25:20.157] list(added = base::setdiff(base::names(base::.GlobalEnv),
[16:25:20.157] ...future.globalenv.names))
[16:25:20.157] else NULL, started = ...future.startTime, version = "1.8")
[16:25:20.157] }, condition = base::local({
[16:25:20.157] c <- base::c
[16:25:20.157] inherits <- base::inherits
[16:25:20.157] invokeRestart <- base::invokeRestart
[16:25:20.157] length <- base::length
[16:25:20.157] list <- base::list
[16:25:20.157] seq.int <- base::seq.int
[16:25:20.157] signalCondition <- base::signalCondition
[16:25:20.157] sys.calls <- base::sys.calls
[16:25:20.157] `[[` <- base::`[[`
[16:25:20.157] `+` <- base::`+`
[16:25:20.157] `<<-` <- base::`<<-`
[16:25:20.157] sysCalls <- function(calls = sys.calls(), from = 1L) {
[16:25:20.157] calls[seq.int(from = from + 12L, to = length(calls) -
[16:25:20.157] 3L)]
[16:25:20.157] }
[16:25:20.157] function(cond) {
[16:25:20.157] is_error <- inherits(cond, "error")
[16:25:20.157] ignore <- !is_error && !is.null(NULL) && inherits(cond,
[16:25:20.157] NULL)
[16:25:20.157] if (is_error) {
[16:25:20.157] sessionInformation <- function() {
[16:25:20.157] list(r = base::R.Version(), locale = base::Sys.getlocale(),
[16:25:20.157] rngkind = base::RNGkind(), namespaces = base::loadedNamespaces(),
[16:25:20.157] search = base::search(), system = base::Sys.info())
[16:25:20.157] }
[16:25:20.157] ...future.conditions[[length(...future.conditions) +
[16:25:20.157] 1L]] <<- list(condition = cond, calls = c(sysCalls(from = ...future.frame),
[16:25:20.157] cond$call), session = sessionInformation(),
[16:25:20.157] timestamp = base::Sys.time(), signaled = 0L)
[16:25:20.157] signalCondition(cond)
[16:25:20.157] }
[16:25:20.157] else if (!ignore && TRUE && inherits(cond, "condition")) {
[16:25:20.157] signal <- FALSE && inherits(cond, character(0))
[16:25:20.157] ...future.conditions[[length(...future.conditions) +
[16:25:20.157] 1L]] <<- list(condition = cond, signaled = base::as.integer(signal))
[16:25:20.157] if (FALSE && !signal) {
[16:25:20.157] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:20.157] {
[16:25:20.157] inherits <- base::inherits
[16:25:20.157] invokeRestart <- base::invokeRestart
[16:25:20.157] is.null <- base::is.null
[16:25:20.157] muffled <- FALSE
[16:25:20.157] if (inherits(cond, "message")) {
[16:25:20.157] muffled <- grepl(pattern, "muffleMessage")
[16:25:20.157] if (muffled)
[16:25:20.157] invokeRestart("muffleMessage")
[16:25:20.157] }
[16:25:20.157] else if (inherits(cond, "warning")) {
[16:25:20.157] muffled <- grepl(pattern, "muffleWarning")
[16:25:20.157] if (muffled)
[16:25:20.157] invokeRestart("muffleWarning")
[16:25:20.157] }
[16:25:20.157] else if (inherits(cond, "condition")) {
[16:25:20.157] if (!is.null(pattern)) {
[16:25:20.157] computeRestarts <- base::computeRestarts
[16:25:20.157] grepl <- base::grepl
[16:25:20.157] restarts <- computeRestarts(cond)
[16:25:20.157] for (restart in restarts) {
[16:25:20.157] name <- restart$name
[16:25:20.157] if (is.null(name))
[16:25:20.157] next
[16:25:20.157] if (!grepl(pattern, name))
[16:25:20.157] next
[16:25:20.157] invokeRestart(restart)
[16:25:20.157] muffled <- TRUE
[16:25:20.157] break
[16:25:20.157] }
[16:25:20.157] }
[16:25:20.157] }
[16:25:20.157] invisible(muffled)
[16:25:20.157] }
[16:25:20.157] muffleCondition(cond, pattern = "^muffle")
[16:25:20.157] }
[16:25:20.157] }
[16:25:20.157] else {
[16:25:20.157] if (TRUE) {
[16:25:20.157] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:20.157] {
[16:25:20.157] inherits <- base::inherits
[16:25:20.157] invokeRestart <- base::invokeRestart
[16:25:20.157] is.null <- base::is.null
[16:25:20.157] muffled <- FALSE
[16:25:20.157] if (inherits(cond, "message")) {
[16:25:20.157] muffled <- grepl(pattern, "muffleMessage")
[16:25:20.157] if (muffled)
[16:25:20.157] invokeRestart("muffleMessage")
[16:25:20.157] }
[16:25:20.157] else if (inherits(cond, "warning")) {
[16:25:20.157] muffled <- grepl(pattern, "muffleWarning")
[16:25:20.157] if (muffled)
[16:25:20.157] invokeRestart("muffleWarning")
[16:25:20.157] }
[16:25:20.157] else if (inherits(cond, "condition")) {
[16:25:20.157] if (!is.null(pattern)) {
[16:25:20.157] computeRestarts <- base::computeRestarts
[16:25:20.157] grepl <- base::grepl
[16:25:20.157] restarts <- computeRestarts(cond)
[16:25:20.157] for (restart in restarts) {
[16:25:20.157] name <- restart$name
[16:25:20.157] if (is.null(name))
[16:25:20.157] next
[16:25:20.157] if (!grepl(pattern, name))
[16:25:20.157] next
[16:25:20.157] invokeRestart(restart)
[16:25:20.157] muffled <- TRUE
[16:25:20.157] break
[16:25:20.157] }
[16:25:20.157] }
[16:25:20.157] }
[16:25:20.157] invisible(muffled)
[16:25:20.157] }
[16:25:20.157] muffleCondition(cond, pattern = "^muffle")
[16:25:20.157] }
[16:25:20.157] }
[16:25:20.157] }
[16:25:20.157] }))
[16:25:20.157] }, error = function(ex) {
[16:25:20.157] base::structure(base::list(value = NULL, visible = NULL,
[16:25:20.157] conditions = ...future.conditions, rng = !identical(base::globalenv()$.Random.seed,
[16:25:20.157] ...future.rng), started = ...future.startTime,
[16:25:20.157] finished = Sys.time(), session_uuid = NA_character_,
[16:25:20.157] version = "1.8"), class = "FutureResult")
[16:25:20.157] }, finally = {
[16:25:20.157] if (!identical(...future.workdir, getwd()))
[16:25:20.157] setwd(...future.workdir)
[16:25:20.157] {
[16:25:20.157] if (identical(getOption("nwarnings"), ...future.oldOptions$nwarnings)) {
[16:25:20.157] ...future.oldOptions$nwarnings <- NULL
[16:25:20.157] }
[16:25:20.157] base::options(...future.oldOptions)
[16:25:20.157] if (.Platform$OS.type == "windows") {
[16:25:20.157] old_names <- names(...future.oldEnvVars)
[16:25:20.157] envs <- base::Sys.getenv()
[16:25:20.157] names <- names(envs)
[16:25:20.157] common <- intersect(names, old_names)
[16:25:20.157] added <- setdiff(names, old_names)
[16:25:20.157] removed <- setdiff(old_names, names)
[16:25:20.157] changed <- common[...future.oldEnvVars[common] !=
[16:25:20.157] envs[common]]
[16:25:20.157] NAMES <- toupper(changed)
[16:25:20.157] args <- list()
[16:25:20.157] for (kk in seq_along(NAMES)) {
[16:25:20.157] name <- changed[[kk]]
[16:25:20.157] NAME <- NAMES[[kk]]
[16:25:20.157] if (name != NAME && is.element(NAME, old_names))
[16:25:20.157] next
[16:25:20.157] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:20.157] }
[16:25:20.157] NAMES <- toupper(added)
[16:25:20.157] for (kk in seq_along(NAMES)) {
[16:25:20.157] name <- added[[kk]]
[16:25:20.157] NAME <- NAMES[[kk]]
[16:25:20.157] if (name != NAME && is.element(NAME, old_names))
[16:25:20.157] next
[16:25:20.157] args[[name]] <- ""
[16:25:20.157] }
[16:25:20.157] NAMES <- toupper(removed)
[16:25:20.157] for (kk in seq_along(NAMES)) {
[16:25:20.157] name <- removed[[kk]]
[16:25:20.157] NAME <- NAMES[[kk]]
[16:25:20.157] if (name != NAME && is.element(NAME, old_names))
[16:25:20.157] next
[16:25:20.157] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:20.157] }
[16:25:20.157] if (length(args) > 0)
[16:25:20.157] base::do.call(base::Sys.setenv, args = args)
[16:25:20.157] args <- names <- old_names <- NAMES <- envs <- common <- added <- removed <- NULL
[16:25:20.157] }
[16:25:20.157] else {
[16:25:20.157] base::do.call(base::Sys.setenv, args = base::as.list(...future.oldEnvVars))
[16:25:20.157] }
[16:25:20.157] {
[16:25:20.157] if (base::length(...future.futureOptionsAdded) >
[16:25:20.157] 0L) {
[16:25:20.157] opts <- base::vector("list", length = base::length(...future.futureOptionsAdded))
[16:25:20.157] base::names(opts) <- ...future.futureOptionsAdded
[16:25:20.157] base::options(opts)
[16:25:20.157] }
[16:25:20.157] {
[16:25:20.157] NULL
[16:25:20.157] options(future.plan = NULL)
[16:25:20.157] if (is.na(NA_character_))
[16:25:20.157] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:20.157] else Sys.setenv(R_FUTURE_PLAN = NA_character_)
[16:25:20.157] future::plan(...future.strategy.old, .cleanup = FALSE,
[16:25:20.157] .init = FALSE)
[16:25:20.157] }
[16:25:20.157] }
[16:25:20.157] }
[16:25:20.157] })
[16:25:20.157] if (TRUE) {
[16:25:20.157] base::sink(type = "output", split = FALSE)
[16:25:20.157] if (TRUE) {
[16:25:20.157] ...future.result$stdout <- base::rawToChar(base::rawConnectionValue(...future.stdout))
[16:25:20.157] }
[16:25:20.157] else {
[16:25:20.157] ...future.result["stdout"] <- base::list(NULL)
[16:25:20.157] }
[16:25:20.157] base::close(...future.stdout)
[16:25:20.157] ...future.stdout <- NULL
[16:25:20.157] }
[16:25:20.157] ...future.result$conditions <- ...future.conditions
[16:25:20.157] ...future.result$finished <- base::Sys.time()
[16:25:20.157] ...future.result
[16:25:20.157] }
[16:25:20.166] plan(): plan_init() of 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function' ... DONE
[16:25:20.167] plan(): nbrOfWorkers() = 2
>
> for (type in c("mirai_multisession")) {
+ mprintf("*** plan('%s') ...", type)
+
+ plan(type)
+ stopifnot(inherits(plan("next"), "mirai_multisession"))
+
+ a <- 0
+ f <- future({
+ b <- 3
+ c <- 2
+ a * b * c
+ })
+ a <- 7 ## Make sure globals are frozen
+ v <- value(f)
+ print(v)
+ stopifnot(v == 0)
+
+ mprintf("*** plan('%s') ... DONE", type)
+ } # for (type ...)
[16:25:20.179] *** plan('mirai_multisession') ...[16:25:20.179] plan(): Setting new future strategy stack:
[16:25:20.179] List of future strategies:
[16:25:20.179] 1. mirai_multisession:
[16:25:20.179] - args: function (expr, substitute = TRUE, envir = parent.frame(), ..., workers = availableCores())
[16:25:20.179] - tweaked: FALSE
[16:25:20.179] - call: plan(type)
[16:25:20.180] plan(): plan_init() of 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function' ...
[16:25:20.180] < mirai | $data >
[16:25:20.182] getGlobalsAndPackages() ...
[16:25:20.182] Not searching for globals
[16:25:20.182] - globals: [0] <none>
[16:25:20.183] getGlobalsAndPackages() ... DONE
[16:25:20.183] getGlobalsAndPackages() ...
[16:25:20.183]
[16:25:20.183] - globals: [0] <none>
[16:25:20.183] getGlobalsAndPackages() ... DONE
[16:25:20.184] Packages needed by the future expression (n = 0): <none>
[16:25:20.184] Packages needed by future strategies (n = 0): <none>
[16:25:20.185] {
[16:25:20.185] {
[16:25:20.185] {
[16:25:20.185] ...future.startTime <- base::Sys.time()
[16:25:20.185] {
[16:25:20.185] {
[16:25:20.185] {
[16:25:20.185] base::local({
[16:25:20.185] has_future <- base::requireNamespace("future",
[16:25:20.185] quietly = TRUE)
[16:25:20.185] if (has_future) {
[16:25:20.185] ns <- base::getNamespace("future")
[16:25:20.185] version <- ns[[".package"]][["version"]]
[16:25:20.185] if (is.null(version))
[16:25:20.185] version <- utils::packageVersion("future")
[16:25:20.185] }
[16:25:20.185] else {
[16:25:20.185] version <- NULL
[16:25:20.185] }
[16:25:20.185] if (!has_future || version < "1.8.0") {
[16:25:20.185] info <- base::c(r_version = base::gsub("R version ",
[16:25:20.185] "", base::R.version$version.string),
[16:25:20.185] platform = base::sprintf("%s (%s-bit)",
[16:25:20.185] base::R.version$platform, 8 * base::.Machine$sizeof.pointer),
[16:25:20.185] os = base::paste(base::Sys.info()[base::c("sysname",
[16:25:20.185] "release", "version")], collapse = " "),
[16:25:20.185] hostname = base::Sys.info()[["nodename"]])
[16:25:20.185] info <- base::sprintf("%s: %s", base::names(info),
[16:25:20.185] info)
[16:25:20.185] info <- base::paste(info, collapse = "; ")
[16:25:20.185] if (!has_future) {
[16:25:20.185] msg <- base::sprintf("Package 'future' is not installed on worker (%s)",
[16:25:20.185] info)
[16:25:20.185] }
[16:25:20.185] else {
[16:25:20.185] msg <- base::sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s",
[16:25:20.185] info, version)
[16:25:20.185] }
[16:25:20.185] base::stop(msg)
[16:25:20.185] }
[16:25:20.185] })
[16:25:20.185] }
[16:25:20.185] ...future.strategy.old <- future::plan("list")
[16:25:20.185] options(future.plan = NULL)
[16:25:20.185] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:20.185] future::plan("default", .cleanup = FALSE, .init = FALSE)
[16:25:20.185] }
[16:25:20.185] ...future.workdir <- getwd()
[16:25:20.185] }
[16:25:20.185] ...future.oldOptions <- base::as.list(base::.Options)
[16:25:20.185] ...future.oldEnvVars <- base::Sys.getenv()
[16:25:20.185] }
[16:25:20.185] base::options(future.startup.script = FALSE, future.globals.onMissing = NULL,
[16:25:20.185] future.globals.maxSize = NULL, future.globals.method = NULL,
[16:25:20.185] future.globals.onMissing = NULL, future.globals.onReference = NULL,
[16:25:20.185] future.globals.resolve = NULL, future.resolve.recursive = NULL,
[16:25:20.185] future.rng.onMisuse = NULL, future.rng.onMisuse.keepFuture = NULL,
[16:25:20.185] future.stdout.windows.reencode = NULL, width = 80L)
[16:25:20.185] ...future.futureOptionsAdded <- base::setdiff(base::names(base::.Options),
[16:25:20.185] base::names(...future.oldOptions))
[16:25:20.185] }
[16:25:20.185] if (FALSE) {
[16:25:20.185] }
[16:25:20.185] else {
[16:25:20.185] if (TRUE) {
[16:25:20.185] ...future.stdout <- base::rawConnection(base::raw(0L),
[16:25:20.185] open = "w")
[16:25:20.185] }
[16:25:20.185] else {
[16:25:20.185] ...future.stdout <- base::file(base::switch(.Platform$OS.type,
[16:25:20.185] windows = "NUL", "/dev/null"), open = "w")
[16:25:20.185] }
[16:25:20.185] base::sink(...future.stdout, type = "output", split = FALSE)
[16:25:20.185] base::on.exit(if (!base::is.null(...future.stdout)) {
[16:25:20.185] base::sink(type = "output", split = FALSE)
[16:25:20.185] base::close(...future.stdout)
[16:25:20.185] }, add = TRUE)
[16:25:20.185] }
[16:25:20.185] ...future.frame <- base::sys.nframe()
[16:25:20.185] ...future.conditions <- base::list()
[16:25:20.185] ...future.rng <- base::globalenv()$.Random.seed
[16:25:20.185] if (FALSE) {
[16:25:20.185] ...future.globalenv.names <- c(base::names(base::.GlobalEnv),
[16:25:20.185] "...future.value", "...future.globalenv.names", ".Random.seed")
[16:25:20.185] }
[16:25:20.185] ...future.result <- base::tryCatch({
[16:25:20.185] base::withCallingHandlers({
[16:25:20.185] ...future.value <- base::withVisible(base::local(NA))
[16:25:20.185] future::FutureResult(value = ...future.value$value,
[16:25:20.185] visible = ...future.value$visible, rng = !identical(base::globalenv()$.Random.seed,
[16:25:20.185] ...future.rng), globalenv = if (FALSE)
[16:25:20.185] list(added = base::setdiff(base::names(base::.GlobalEnv),
[16:25:20.185] ...future.globalenv.names))
[16:25:20.185] else NULL, started = ...future.startTime, version = "1.8")
[16:25:20.185] }, condition = base::local({
[16:25:20.185] c <- base::c
[16:25:20.185] inherits <- base::inherits
[16:25:20.185] invokeRestart <- base::invokeRestart
[16:25:20.185] length <- base::length
[16:25:20.185] list <- base::list
[16:25:20.185] seq.int <- base::seq.int
[16:25:20.185] signalCondition <- base::signalCondition
[16:25:20.185] sys.calls <- base::sys.calls
[16:25:20.185] `[[` <- base::`[[`
[16:25:20.185] `+` <- base::`+`
[16:25:20.185] `<<-` <- base::`<<-`
[16:25:20.185] sysCalls <- function(calls = sys.calls(), from = 1L) {
[16:25:20.185] calls[seq.int(from = from + 12L, to = length(calls) -
[16:25:20.185] 3L)]
[16:25:20.185] }
[16:25:20.185] function(cond) {
[16:25:20.185] is_error <- inherits(cond, "error")
[16:25:20.185] ignore <- !is_error && !is.null(NULL) && inherits(cond,
[16:25:20.185] NULL)
[16:25:20.185] if (is_error) {
[16:25:20.185] sessionInformation <- function() {
[16:25:20.185] list(r = base::R.Version(), locale = base::Sys.getlocale(),
[16:25:20.185] rngkind = base::RNGkind(), namespaces = base::loadedNamespaces(),
[16:25:20.185] search = base::search(), system = base::Sys.info())
[16:25:20.185] }
[16:25:20.185] ...future.conditions[[length(...future.conditions) +
[16:25:20.185] 1L]] <<- list(condition = cond, calls = c(sysCalls(from = ...future.frame),
[16:25:20.185] cond$call), session = sessionInformation(),
[16:25:20.185] timestamp = base::Sys.time(), signaled = 0L)
[16:25:20.185] signalCondition(cond)
[16:25:20.185] }
[16:25:20.185] else if (!ignore && TRUE && inherits(cond, "condition")) {
[16:25:20.185] signal <- FALSE && inherits(cond, character(0))
[16:25:20.185] ...future.conditions[[length(...future.conditions) +
[16:25:20.185] 1L]] <<- list(condition = cond, signaled = base::as.integer(signal))
[16:25:20.185] if (FALSE && !signal) {
[16:25:20.185] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:20.185] {
[16:25:20.185] inherits <- base::inherits
[16:25:20.185] invokeRestart <- base::invokeRestart
[16:25:20.185] is.null <- base::is.null
[16:25:20.185] muffled <- FALSE
[16:25:20.185] if (inherits(cond, "message")) {
[16:25:20.185] muffled <- grepl(pattern, "muffleMessage")
[16:25:20.185] if (muffled)
[16:25:20.185] invokeRestart("muffleMessage")
[16:25:20.185] }
[16:25:20.185] else if (inherits(cond, "warning")) {
[16:25:20.185] muffled <- grepl(pattern, "muffleWarning")
[16:25:20.185] if (muffled)
[16:25:20.185] invokeRestart("muffleWarning")
[16:25:20.185] }
[16:25:20.185] else if (inherits(cond, "condition")) {
[16:25:20.185] if (!is.null(pattern)) {
[16:25:20.185] computeRestarts <- base::computeRestarts
[16:25:20.185] grepl <- base::grepl
[16:25:20.185] restarts <- computeRestarts(cond)
[16:25:20.185] for (restart in restarts) {
[16:25:20.185] name <- restart$name
[16:25:20.185] if (is.null(name))
[16:25:20.185] next
[16:25:20.185] if (!grepl(pattern, name))
[16:25:20.185] next
[16:25:20.185] invokeRestart(restart)
[16:25:20.185] muffled <- TRUE
[16:25:20.185] break
[16:25:20.185] }
[16:25:20.185] }
[16:25:20.185] }
[16:25:20.185] invisible(muffled)
[16:25:20.185] }
[16:25:20.185] muffleCondition(cond, pattern = "^muffle")
[16:25:20.185] }
[16:25:20.185] }
[16:25:20.185] else {
[16:25:20.185] if (TRUE) {
[16:25:20.185] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:20.185] {
[16:25:20.185] inherits <- base::inherits
[16:25:20.185] invokeRestart <- base::invokeRestart
[16:25:20.185] is.null <- base::is.null
[16:25:20.185] muffled <- FALSE
[16:25:20.185] if (inherits(cond, "message")) {
[16:25:20.185] muffled <- grepl(pattern, "muffleMessage")
[16:25:20.185] if (muffled)
[16:25:20.185] invokeRestart("muffleMessage")
[16:25:20.185] }
[16:25:20.185] else if (inherits(cond, "warning")) {
[16:25:20.185] muffled <- grepl(pattern, "muffleWarning")
[16:25:20.185] if (muffled)
[16:25:20.185] invokeRestart("muffleWarning")
[16:25:20.185] }
[16:25:20.185] else if (inherits(cond, "condition")) {
[16:25:20.185] if (!is.null(pattern)) {
[16:25:20.185] computeRestarts <- base::computeRestarts
[16:25:20.185] grepl <- base::grepl
[16:25:20.185] restarts <- computeRestarts(cond)
[16:25:20.185] for (restart in restarts) {
[16:25:20.185] name <- restart$name
[16:25:20.185] if (is.null(name))
[16:25:20.185] next
[16:25:20.185] if (!grepl(pattern, name))
[16:25:20.185] next
[16:25:20.185] invokeRestart(restart)
[16:25:20.185] muffled <- TRUE
[16:25:20.185] break
[16:25:20.185] }
[16:25:20.185] }
[16:25:20.185] }
[16:25:20.185] invisible(muffled)
[16:25:20.185] }
[16:25:20.185] muffleCondition(cond, pattern = "^muffle")
[16:25:20.185] }
[16:25:20.185] }
[16:25:20.185] }
[16:25:20.185] }))
[16:25:20.185] }, error = function(ex) {
[16:25:20.185] base::structure(base::list(value = NULL, visible = NULL,
[16:25:20.185] conditions = ...future.conditions, rng = !identical(base::globalenv()$.Random.seed,
[16:25:20.185] ...future.rng), started = ...future.startTime,
[16:25:20.185] finished = Sys.time(), session_uuid = NA_character_,
[16:25:20.185] version = "1.8"), class = "FutureResult")
[16:25:20.185] }, finally = {
[16:25:20.185] if (!identical(...future.workdir, getwd()))
[16:25:20.185] setwd(...future.workdir)
[16:25:20.185] {
[16:25:20.185] if (identical(getOption("nwarnings"), ...future.oldOptions$nwarnings)) {
[16:25:20.185] ...future.oldOptions$nwarnings <- NULL
[16:25:20.185] }
[16:25:20.185] base::options(...future.oldOptions)
[16:25:20.185] if (.Platform$OS.type == "windows") {
[16:25:20.185] old_names <- names(...future.oldEnvVars)
[16:25:20.185] envs <- base::Sys.getenv()
[16:25:20.185] names <- names(envs)
[16:25:20.185] common <- intersect(names, old_names)
[16:25:20.185] added <- setdiff(names, old_names)
[16:25:20.185] removed <- setdiff(old_names, names)
[16:25:20.185] changed <- common[...future.oldEnvVars[common] !=
[16:25:20.185] envs[common]]
[16:25:20.185] NAMES <- toupper(changed)
[16:25:20.185] args <- list()
[16:25:20.185] for (kk in seq_along(NAMES)) {
[16:25:20.185] name <- changed[[kk]]
[16:25:20.185] NAME <- NAMES[[kk]]
[16:25:20.185] if (name != NAME && is.element(NAME, old_names))
[16:25:20.185] next
[16:25:20.185] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:20.185] }
[16:25:20.185] NAMES <- toupper(added)
[16:25:20.185] for (kk in seq_along(NAMES)) {
[16:25:20.185] name <- added[[kk]]
[16:25:20.185] NAME <- NAMES[[kk]]
[16:25:20.185] if (name != NAME && is.element(NAME, old_names))
[16:25:20.185] next
[16:25:20.185] args[[name]] <- ""
[16:25:20.185] }
[16:25:20.185] NAMES <- toupper(removed)
[16:25:20.185] for (kk in seq_along(NAMES)) {
[16:25:20.185] name <- removed[[kk]]
[16:25:20.185] NAME <- NAMES[[kk]]
[16:25:20.185] if (name != NAME && is.element(NAME, old_names))
[16:25:20.185] next
[16:25:20.185] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:20.185] }
[16:25:20.185] if (length(args) > 0)
[16:25:20.185] base::do.call(base::Sys.setenv, args = args)
[16:25:20.185] args <- names <- old_names <- NAMES <- envs <- common <- added <- removed <- NULL
[16:25:20.185] }
[16:25:20.185] else {
[16:25:20.185] base::do.call(base::Sys.setenv, args = base::as.list(...future.oldEnvVars))
[16:25:20.185] }
[16:25:20.185] {
[16:25:20.185] if (base::length(...future.futureOptionsAdded) >
[16:25:20.185] 0L) {
[16:25:20.185] opts <- base::vector("list", length = base::length(...future.futureOptionsAdded))
[16:25:20.185] base::names(opts) <- ...future.futureOptionsAdded
[16:25:20.185] base::options(opts)
[16:25:20.185] }
[16:25:20.185] {
[16:25:20.185] NULL
[16:25:20.185] options(future.plan = NULL)
[16:25:20.185] if (is.na(NA_character_))
[16:25:20.185] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:20.185] else Sys.setenv(R_FUTURE_PLAN = NA_character_)
[16:25:20.185] future::plan(...future.strategy.old, .cleanup = FALSE,
[16:25:20.185] .init = FALSE)
[16:25:20.185] }
[16:25:20.185] }
[16:25:20.185] }
[16:25:20.185] })
[16:25:20.185] if (TRUE) {
[16:25:20.185] base::sink(type = "output", split = FALSE)
[16:25:20.185] if (TRUE) {
[16:25:20.185] ...future.result$stdout <- base::rawToChar(base::rawConnectionValue(...future.stdout))
[16:25:20.185] }
[16:25:20.185] else {
[16:25:20.185] ...future.result["stdout"] <- base::list(NULL)
[16:25:20.185] }
[16:25:20.185] base::close(...future.stdout)
[16:25:20.185] ...future.stdout <- NULL
[16:25:20.185] }
[16:25:20.185] ...future.result$conditions <- ...future.conditions
[16:25:20.185] ...future.result$finished <- base::Sys.time()
[16:25:20.185] ...future.result
[16:25:20.185] }
[16:25:20.194] plan(): plan_init() of 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function' ... DONE
[16:25:20.194] plan(): nbrOfWorkers() = 2
[16:25:20.195] getGlobalsAndPackages() ...
[16:25:20.195] Searching for globals...
[16:25:20.213] - globals found: [4] '{', '<-', '*', 'a'
[16:25:20.214] Searching for globals ... DONE
[16:25:20.214] Resolving globals: FALSE
[16:25:20.216] The total size of the 1 globals is 56 bytes (56 bytes)
[16:25:20.216] The total size of the 1 globals exported for future expression ('{; b <- 3; c <- 2; a * b * c; }') is 56 bytes.. This exceeds the maximum allowed size of 500.00 MiB (option 'future.globals.maxSize'). There is one global: 'a' (56 bytes of class 'numeric')
[16:25:20.217] - globals: [1] 'a'
[16:25:20.217]
[16:25:20.217] getGlobalsAndPackages() ... DONE
[16:25:20.218] run() for 'Future' ...
[16:25:20.218] - state: 'created'
[16:25:20.218] - Future backend: 'FutureStrategy', 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function'
[16:25:20.220] - Future class: 'MiraiFuture', 'MultiprocessFuture', 'Future', 'environment'
[16:25:20.221] - Copy elements of temporary 'MiraiFuture' to final 'Future' object ...
[16:25:20.221] - Field: 'label'
[16:25:20.221] - Field: 'local'
[16:25:20.221] - Field: 'owner'
[16:25:20.222] - Field: 'envir'
[16:25:20.222] - Field: 'packages'
[16:25:20.222] - Field: 'gc'
[16:25:20.222] - Field: 'conditions'
[16:25:20.223] - Field: 'expr'
[16:25:20.223] - Field: 'uuid'
[16:25:20.223] - Field: 'seed'
[16:25:20.223] - Field: 'version'
[16:25:20.224] - Field: 'result'
[16:25:20.224] - Field: 'asynchronous'
[16:25:20.224] - Field: 'calls'
[16:25:20.224] - Field: 'globals'
[16:25:20.225] - Field: 'stdout'
[16:25:20.225] - Field: 'earlySignal'
[16:25:20.225] - Field: 'lazy'
[16:25:20.225] - Field: 'state'
[16:25:20.226] - Field: '.cluster'
[16:25:20.226] - Copy elements of temporary 'MiraiFuture' to final 'Future' object ... done
[16:25:20.226] - Launch lazy future ...
[16:25:20.227] Packages needed by the future expression (n = 0): <none>
[16:25:20.227] Packages needed by future strategies (n = 0): <none>
[16:25:20.227] {
[16:25:20.227] {
[16:25:20.227] {
[16:25:20.227] ...future.startTime <- base::Sys.time()
[16:25:20.227] {
[16:25:20.227] {
[16:25:20.227] {
[16:25:20.227] base::local({
[16:25:20.227] has_future <- base::requireNamespace("future",
[16:25:20.227] quietly = TRUE)
[16:25:20.227] if (has_future) {
[16:25:20.227] ns <- base::getNamespace("future")
[16:25:20.227] version <- ns[[".package"]][["version"]]
[16:25:20.227] if (is.null(version))
[16:25:20.227] version <- utils::packageVersion("future")
[16:25:20.227] }
[16:25:20.227] else {
[16:25:20.227] version <- NULL
[16:25:20.227] }
[16:25:20.227] if (!has_future || version < "1.8.0") {
[16:25:20.227] info <- base::c(r_version = base::gsub("R version ",
[16:25:20.227] "", base::R.version$version.string),
[16:25:20.227] platform = base::sprintf("%s (%s-bit)",
[16:25:20.227] base::R.version$platform, 8 * base::.Machine$sizeof.pointer),
[16:25:20.227] os = base::paste(base::Sys.info()[base::c("sysname",
[16:25:20.227] "release", "version")], collapse = " "),
[16:25:20.227] hostname = base::Sys.info()[["nodename"]])
[16:25:20.227] info <- base::sprintf("%s: %s", base::names(info),
[16:25:20.227] info)
[16:25:20.227] info <- base::paste(info, collapse = "; ")
[16:25:20.227] if (!has_future) {
[16:25:20.227] msg <- base::sprintf("Package 'future' is not installed on worker (%s)",
[16:25:20.227] info)
[16:25:20.227] }
[16:25:20.227] else {
[16:25:20.227] msg <- base::sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s",
[16:25:20.227] info, version)
[16:25:20.227] }
[16:25:20.227] base::stop(msg)
[16:25:20.227] }
[16:25:20.227] })
[16:25:20.227] }
[16:25:20.227] ...future.strategy.old <- future::plan("list")
[16:25:20.227] options(future.plan = NULL)
[16:25:20.227] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:20.227] future::plan("default", .cleanup = FALSE, .init = FALSE)
[16:25:20.227] }
[16:25:20.227] ...future.workdir <- getwd()
[16:25:20.227] }
[16:25:20.227] ...future.oldOptions <- base::as.list(base::.Options)
[16:25:20.227] ...future.oldEnvVars <- base::Sys.getenv()
[16:25:20.227] }
[16:25:20.227] base::options(future.startup.script = FALSE, future.globals.onMissing = NULL,
[16:25:20.227] future.globals.maxSize = NULL, future.globals.method = NULL,
[16:25:20.227] future.globals.onMissing = NULL, future.globals.onReference = NULL,
[16:25:20.227] future.globals.resolve = NULL, future.resolve.recursive = NULL,
[16:25:20.227] future.rng.onMisuse = NULL, future.rng.onMisuse.keepFuture = NULL,
[16:25:20.227] future.stdout.windows.reencode = NULL, width = 80L)
[16:25:20.227] ...future.futureOptionsAdded <- base::setdiff(base::names(base::.Options),
[16:25:20.227] base::names(...future.oldOptions))
[16:25:20.227] }
[16:25:20.227] if (FALSE) {
[16:25:20.227] }
[16:25:20.227] else {
[16:25:20.227] if (TRUE) {
[16:25:20.227] ...future.stdout <- base::rawConnection(base::raw(0L),
[16:25:20.227] open = "w")
[16:25:20.227] }
[16:25:20.227] else {
[16:25:20.227] ...future.stdout <- base::file(base::switch(.Platform$OS.type,
[16:25:20.227] windows = "NUL", "/dev/null"), open = "w")
[16:25:20.227] }
[16:25:20.227] base::sink(...future.stdout, type = "output", split = FALSE)
[16:25:20.227] base::on.exit(if (!base::is.null(...future.stdout)) {
[16:25:20.227] base::sink(type = "output", split = FALSE)
[16:25:20.227] base::close(...future.stdout)
[16:25:20.227] }, add = TRUE)
[16:25:20.227] }
[16:25:20.227] ...future.frame <- base::sys.nframe()
[16:25:20.227] ...future.conditions <- base::list()
[16:25:20.227] ...future.rng <- base::globalenv()$.Random.seed
[16:25:20.227] if (FALSE) {
[16:25:20.227] ...future.globalenv.names <- c(base::names(base::.GlobalEnv),
[16:25:20.227] "...future.value", "...future.globalenv.names", ".Random.seed")
[16:25:20.227] }
[16:25:20.227] ...future.result <- base::tryCatch({
[16:25:20.227] base::withCallingHandlers({
[16:25:20.227] ...future.value <- base::withVisible(base::local({
[16:25:20.227] b <- 3
[16:25:20.227] c <- 2
[16:25:20.227] a * b * c
[16:25:20.227] }))
[16:25:20.227] future::FutureResult(value = ...future.value$value,
[16:25:20.227] visible = ...future.value$visible, rng = !identical(base::globalenv()$.Random.seed,
[16:25:20.227] ...future.rng), globalenv = if (FALSE)
[16:25:20.227] list(added = base::setdiff(base::names(base::.GlobalEnv),
[16:25:20.227] ...future.globalenv.names))
[16:25:20.227] else NULL, started = ...future.startTime, version = "1.8")
[16:25:20.227] }, condition = base::local({
[16:25:20.227] c <- base::c
[16:25:20.227] inherits <- base::inherits
[16:25:20.227] invokeRestart <- base::invokeRestart
[16:25:20.227] length <- base::length
[16:25:20.227] list <- base::list
[16:25:20.227] seq.int <- base::seq.int
[16:25:20.227] signalCondition <- base::signalCondition
[16:25:20.227] sys.calls <- base::sys.calls
[16:25:20.227] `[[` <- base::`[[`
[16:25:20.227] `+` <- base::`+`
[16:25:20.227] `<<-` <- base::`<<-`
[16:25:20.227] sysCalls <- function(calls = sys.calls(), from = 1L) {
[16:25:20.227] calls[seq.int(from = from + 12L, to = length(calls) -
[16:25:20.227] 3L)]
[16:25:20.227] }
[16:25:20.227] function(cond) {
[16:25:20.227] is_error <- inherits(cond, "error")
[16:25:20.227] ignore <- !is_error && !is.null(NULL) && inherits(cond,
[16:25:20.227] NULL)
[16:25:20.227] if (is_error) {
[16:25:20.227] sessionInformation <- function() {
[16:25:20.227] list(r = base::R.Version(), locale = base::Sys.getlocale(),
[16:25:20.227] rngkind = base::RNGkind(), namespaces = base::loadedNamespaces(),
[16:25:20.227] search = base::search(), system = base::Sys.info())
[16:25:20.227] }
[16:25:20.227] ...future.conditions[[length(...future.conditions) +
[16:25:20.227] 1L]] <<- list(condition = cond, calls = c(sysCalls(from = ...future.frame),
[16:25:20.227] cond$call), session = sessionInformation(),
[16:25:20.227] timestamp = base::Sys.time(), signaled = 0L)
[16:25:20.227] signalCondition(cond)
[16:25:20.227] }
[16:25:20.227] else if (!ignore && TRUE && inherits(cond, "condition")) {
[16:25:20.227] signal <- FALSE && inherits(cond, character(0))
[16:25:20.227] ...future.conditions[[length(...future.conditions) +
[16:25:20.227] 1L]] <<- list(condition = cond, signaled = base::as.integer(signal))
[16:25:20.227] if (FALSE && !signal) {
[16:25:20.227] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:20.227] {
[16:25:20.227] inherits <- base::inherits
[16:25:20.227] invokeRestart <- base::invokeRestart
[16:25:20.227] is.null <- base::is.null
[16:25:20.227] muffled <- FALSE
[16:25:20.227] if (inherits(cond, "message")) {
[16:25:20.227] muffled <- grepl(pattern, "muffleMessage")
[16:25:20.227] if (muffled)
[16:25:20.227] invokeRestart("muffleMessage")
[16:25:20.227] }
[16:25:20.227] else if (inherits(cond, "warning")) {
[16:25:20.227] muffled <- grepl(pattern, "muffleWarning")
[16:25:20.227] if (muffled)
[16:25:20.227] invokeRestart("muffleWarning")
[16:25:20.227] }
[16:25:20.227] else if (inherits(cond, "condition")) {
[16:25:20.227] if (!is.null(pattern)) {
[16:25:20.227] computeRestarts <- base::computeRestarts
[16:25:20.227] grepl <- base::grepl
[16:25:20.227] restarts <- computeRestarts(cond)
[16:25:20.227] for (restart in restarts) {
[16:25:20.227] name <- restart$name
[16:25:20.227] if (is.null(name))
[16:25:20.227] next
[16:25:20.227] if (!grepl(pattern, name))
[16:25:20.227] next
[16:25:20.227] invokeRestart(restart)
[16:25:20.227] muffled <- TRUE
[16:25:20.227] break
[16:25:20.227] }
[16:25:20.227] }
[16:25:20.227] }
[16:25:20.227] invisible(muffled)
[16:25:20.227] }
[16:25:20.227] muffleCondition(cond, pattern = "^muffle")
[16:25:20.227] }
[16:25:20.227] }
[16:25:20.227] else {
[16:25:20.227] if (TRUE) {
[16:25:20.227] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:20.227] {
[16:25:20.227] inherits <- base::inherits
[16:25:20.227] invokeRestart <- base::invokeRestart
[16:25:20.227] is.null <- base::is.null
[16:25:20.227] muffled <- FALSE
[16:25:20.227] if (inherits(cond, "message")) {
[16:25:20.227] muffled <- grepl(pattern, "muffleMessage")
[16:25:20.227] if (muffled)
[16:25:20.227] invokeRestart("muffleMessage")
[16:25:20.227] }
[16:25:20.227] else if (inherits(cond, "warning")) {
[16:25:20.227] muffled <- grepl(pattern, "muffleWarning")
[16:25:20.227] if (muffled)
[16:25:20.227] invokeRestart("muffleWarning")
[16:25:20.227] }
[16:25:20.227] else if (inherits(cond, "condition")) {
[16:25:20.227] if (!is.null(pattern)) {
[16:25:20.227] computeRestarts <- base::computeRestarts
[16:25:20.227] grepl <- base::grepl
[16:25:20.227] restarts <- computeRestarts(cond)
[16:25:20.227] for (restart in restarts) {
[16:25:20.227] name <- restart$name
[16:25:20.227] if (is.null(name))
[16:25:20.227] next
[16:25:20.227] if (!grepl(pattern, name))
[16:25:20.227] next
[16:25:20.227] invokeRestart(restart)
[16:25:20.227] muffled <- TRUE
[16:25:20.227] break
[16:25:20.227] }
[16:25:20.227] }
[16:25:20.227] }
[16:25:20.227] invisible(muffled)
[16:25:20.227] }
[16:25:20.227] muffleCondition(cond, pattern = "^muffle")
[16:25:20.227] }
[16:25:20.227] }
[16:25:20.227] }
[16:25:20.227] }))
[16:25:20.227] }, error = function(ex) {
[16:25:20.227] base::structure(base::list(value = NULL, visible = NULL,
[16:25:20.227] conditions = ...future.conditions, rng = !identical(base::globalenv()$.Random.seed,
[16:25:20.227] ...future.rng), started = ...future.startTime,
[16:25:20.227] finished = Sys.time(), session_uuid = NA_character_,
[16:25:20.227] version = "1.8"), class = "FutureResult")
[16:25:20.227] }, finally = {
[16:25:20.227] if (!identical(...future.workdir, getwd()))
[16:25:20.227] setwd(...future.workdir)
[16:25:20.227] {
[16:25:20.227] if (identical(getOption("nwarnings"), ...future.oldOptions$nwarnings)) {
[16:25:20.227] ...future.oldOptions$nwarnings <- NULL
[16:25:20.227] }
[16:25:20.227] base::options(...future.oldOptions)
[16:25:20.227] if (.Platform$OS.type == "windows") {
[16:25:20.227] old_names <- names(...future.oldEnvVars)
[16:25:20.227] envs <- base::Sys.getenv()
[16:25:20.227] names <- names(envs)
[16:25:20.227] common <- intersect(names, old_names)
[16:25:20.227] added <- setdiff(names, old_names)
[16:25:20.227] removed <- setdiff(old_names, names)
[16:25:20.227] changed <- common[...future.oldEnvVars[common] !=
[16:25:20.227] envs[common]]
[16:25:20.227] NAMES <- toupper(changed)
[16:25:20.227] args <- list()
[16:25:20.227] for (kk in seq_along(NAMES)) {
[16:25:20.227] name <- changed[[kk]]
[16:25:20.227] NAME <- NAMES[[kk]]
[16:25:20.227] if (name != NAME && is.element(NAME, old_names))
[16:25:20.227] next
[16:25:20.227] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:20.227] }
[16:25:20.227] NAMES <- toupper(added)
[16:25:20.227] for (kk in seq_along(NAMES)) {
[16:25:20.227] name <- added[[kk]]
[16:25:20.227] NAME <- NAMES[[kk]]
[16:25:20.227] if (name != NAME && is.element(NAME, old_names))
[16:25:20.227] next
[16:25:20.227] args[[name]] <- ""
[16:25:20.227] }
[16:25:20.227] NAMES <- toupper(removed)
[16:25:20.227] for (kk in seq_along(NAMES)) {
[16:25:20.227] name <- removed[[kk]]
[16:25:20.227] NAME <- NAMES[[kk]]
[16:25:20.227] if (name != NAME && is.element(NAME, old_names))
[16:25:20.227] next
[16:25:20.227] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:20.227] }
[16:25:20.227] if (length(args) > 0)
[16:25:20.227] base::do.call(base::Sys.setenv, args = args)
[16:25:20.227] args <- names <- old_names <- NAMES <- envs <- common <- added <- removed <- NULL
[16:25:20.227] }
[16:25:20.227] else {
[16:25:20.227] base::do.call(base::Sys.setenv, args = base::as.list(...future.oldEnvVars))
[16:25:20.227] }
[16:25:20.227] {
[16:25:20.227] if (base::length(...future.futureOptionsAdded) >
[16:25:20.227] 0L) {
[16:25:20.227] opts <- base::vector("list", length = base::length(...future.futureOptionsAdded))
[16:25:20.227] base::names(opts) <- ...future.futureOptionsAdded
[16:25:20.227] base::options(opts)
[16:25:20.227] }
[16:25:20.227] {
[16:25:20.227] NULL
[16:25:20.227] options(future.plan = NULL)
[16:25:20.227] if (is.na(NA_character_))
[16:25:20.227] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:20.227] else Sys.setenv(R_FUTURE_PLAN = NA_character_)
[16:25:20.227] future::plan(...future.strategy.old, .cleanup = FALSE,
[16:25:20.227] .init = FALSE)
[16:25:20.227] }
[16:25:20.227] }
[16:25:20.227] }
[16:25:20.227] })
[16:25:20.227] if (TRUE) {
[16:25:20.227] base::sink(type = "output", split = FALSE)
[16:25:20.227] if (TRUE) {
[16:25:20.227] ...future.result$stdout <- base::rawToChar(base::rawConnectionValue(...future.stdout))
[16:25:20.227] }
[16:25:20.227] else {
[16:25:20.227] ...future.result["stdout"] <- base::list(NULL)
[16:25:20.227] }
[16:25:20.227] base::close(...future.stdout)
[16:25:20.227] ...future.stdout <- NULL
[16:25:20.227] }
[16:25:20.227] ...future.result$conditions <- ...future.conditions
[16:25:20.227] ...future.result$finished <- base::Sys.time()
[16:25:20.227] ...future.result
[16:25:20.227] }
[16:25:20.231] - Launch lazy future ... done
[16:25:20.232] run() for 'MiraiFuture' ... done
[1] 0
[16:25:20.236] *** plan('mirai_multisession') ... DONE>
>
> message("*** Assert that default backend can be overridden ...")
*** Assert that default backend can be overridden ...
>
> mpid <- Sys.getpid()
> print(mpid)
[1] 149804
>
> plan(mirai_multisession)
[16:25:20.237] plan(): Setting new future strategy stack:
[16:25:20.237] List of future strategies:
[16:25:20.237] 1. mirai_multisession:
[16:25:20.237] - args: function (expr, substitute = TRUE, envir = parent.frame(), ..., workers = availableCores())
[16:25:20.237] - tweaked: FALSE
[16:25:20.237] - call: plan(mirai_multisession)
[16:25:20.238] plan(): plan_init() of 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function' ...
[16:25:20.239] < mirai | $data >
[16:25:20.242] getGlobalsAndPackages() ...
[16:25:20.243] Not searching for globals
[16:25:20.243] - globals: [0] <none>
[16:25:20.243] getGlobalsAndPackages() ... DONE
[16:25:20.244] getGlobalsAndPackages() ...
[16:25:20.244]
[16:25:20.244] - globals: [0] <none>
[16:25:20.244] getGlobalsAndPackages() ... DONE
[16:25:20.245] Packages needed by the future expression (n = 0): <none>
[16:25:20.245] Packages needed by future strategies (n = 0): <none>
[16:25:20.247] {
[16:25:20.247] {
[16:25:20.247] {
[16:25:20.247] ...future.startTime <- base::Sys.time()
[16:25:20.247] {
[16:25:20.247] {
[16:25:20.247] {
[16:25:20.247] base::local({
[16:25:20.247] has_future <- base::requireNamespace("future",
[16:25:20.247] quietly = TRUE)
[16:25:20.247] if (has_future) {
[16:25:20.247] ns <- base::getNamespace("future")
[16:25:20.247] version <- ns[[".package"]][["version"]]
[16:25:20.247] if (is.null(version))
[16:25:20.247] version <- utils::packageVersion("future")
[16:25:20.247] }
[16:25:20.247] else {
[16:25:20.247] version <- NULL
[16:25:20.247] }
[16:25:20.247] if (!has_future || version < "1.8.0") {
[16:25:20.247] info <- base::c(r_version = base::gsub("R version ",
[16:25:20.247] "", base::R.version$version.string),
[16:25:20.247] platform = base::sprintf("%s (%s-bit)",
[16:25:20.247] base::R.version$platform, 8 * base::.Machine$sizeof.pointer),
[16:25:20.247] os = base::paste(base::Sys.info()[base::c("sysname",
[16:25:20.247] "release", "version")], collapse = " "),
[16:25:20.247] hostname = base::Sys.info()[["nodename"]])
[16:25:20.247] info <- base::sprintf("%s: %s", base::names(info),
[16:25:20.247] info)
[16:25:20.247] info <- base::paste(info, collapse = "; ")
[16:25:20.247] if (!has_future) {
[16:25:20.247] msg <- base::sprintf("Package 'future' is not installed on worker (%s)",
[16:25:20.247] info)
[16:25:20.247] }
[16:25:20.247] else {
[16:25:20.247] msg <- base::sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s",
[16:25:20.247] info, version)
[16:25:20.247] }
[16:25:20.247] base::stop(msg)
[16:25:20.247] }
[16:25:20.247] })
[16:25:20.247] }
[16:25:20.247] ...future.strategy.old <- future::plan("list")
[16:25:20.247] options(future.plan = NULL)
[16:25:20.247] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:20.247] future::plan("default", .cleanup = FALSE, .init = FALSE)
[16:25:20.247] }
[16:25:20.247] ...future.workdir <- getwd()
[16:25:20.247] }
[16:25:20.247] ...future.oldOptions <- base::as.list(base::.Options)
[16:25:20.247] ...future.oldEnvVars <- base::Sys.getenv()
[16:25:20.247] }
[16:25:20.247] base::options(future.startup.script = FALSE, future.globals.onMissing = NULL,
[16:25:20.247] future.globals.maxSize = NULL, future.globals.method = NULL,
[16:25:20.247] future.globals.onMissing = NULL, future.globals.onReference = NULL,
[16:25:20.247] future.globals.resolve = NULL, future.resolve.recursive = NULL,
[16:25:20.247] future.rng.onMisuse = NULL, future.rng.onMisuse.keepFuture = NULL,
[16:25:20.247] future.stdout.windows.reencode = NULL, width = 80L)
[16:25:20.247] ...future.futureOptionsAdded <- base::setdiff(base::names(base::.Options),
[16:25:20.247] base::names(...future.oldOptions))
[16:25:20.247] }
[16:25:20.247] if (FALSE) {
[16:25:20.247] }
[16:25:20.247] else {
[16:25:20.247] if (TRUE) {
[16:25:20.247] ...future.stdout <- base::rawConnection(base::raw(0L),
[16:25:20.247] open = "w")
[16:25:20.247] }
[16:25:20.247] else {
[16:25:20.247] ...future.stdout <- base::file(base::switch(.Platform$OS.type,
[16:25:20.247] windows = "NUL", "/dev/null"), open = "w")
[16:25:20.247] }
[16:25:20.247] base::sink(...future.stdout, type = "output", split = FALSE)
[16:25:20.247] base::on.exit(if (!base::is.null(...future.stdout)) {
[16:25:20.247] base::sink(type = "output", split = FALSE)
[16:25:20.247] base::close(...future.stdout)
[16:25:20.247] }, add = TRUE)
[16:25:20.247] }
[16:25:20.247] ...future.frame <- base::sys.nframe()
[16:25:20.247] ...future.conditions <- base::list()
[16:25:20.247] ...future.rng <- base::globalenv()$.Random.seed
[16:25:20.247] if (FALSE) {
[16:25:20.247] ...future.globalenv.names <- c(base::names(base::.GlobalEnv),
[16:25:20.247] "...future.value", "...future.globalenv.names", ".Random.seed")
[16:25:20.247] }
[16:25:20.247] ...future.result <- base::tryCatch({
[16:25:20.247] base::withCallingHandlers({
[16:25:20.247] ...future.value <- base::withVisible(base::local(NA))
[16:25:20.247] future::FutureResult(value = ...future.value$value,
[16:25:20.247] visible = ...future.value$visible, rng = !identical(base::globalenv()$.Random.seed,
[16:25:20.247] ...future.rng), globalenv = if (FALSE)
[16:25:20.247] list(added = base::setdiff(base::names(base::.GlobalEnv),
[16:25:20.247] ...future.globalenv.names))
[16:25:20.247] else NULL, started = ...future.startTime, version = "1.8")
[16:25:20.247] }, condition = base::local({
[16:25:20.247] c <- base::c
[16:25:20.247] inherits <- base::inherits
[16:25:20.247] invokeRestart <- base::invokeRestart
[16:25:20.247] length <- base::length
[16:25:20.247] list <- base::list
[16:25:20.247] seq.int <- base::seq.int
[16:25:20.247] signalCondition <- base::signalCondition
[16:25:20.247] sys.calls <- base::sys.calls
[16:25:20.247] `[[` <- base::`[[`
[16:25:20.247] `+` <- base::`+`
[16:25:20.247] `<<-` <- base::`<<-`
[16:25:20.247] sysCalls <- function(calls = sys.calls(), from = 1L) {
[16:25:20.247] calls[seq.int(from = from + 12L, to = length(calls) -
[16:25:20.247] 3L)]
[16:25:20.247] }
[16:25:20.247] function(cond) {
[16:25:20.247] is_error <- inherits(cond, "error")
[16:25:20.247] ignore <- !is_error && !is.null(NULL) && inherits(cond,
[16:25:20.247] NULL)
[16:25:20.247] if (is_error) {
[16:25:20.247] sessionInformation <- function() {
[16:25:20.247] list(r = base::R.Version(), locale = base::Sys.getlocale(),
[16:25:20.247] rngkind = base::RNGkind(), namespaces = base::loadedNamespaces(),
[16:25:20.247] search = base::search(), system = base::Sys.info())
[16:25:20.247] }
[16:25:20.247] ...future.conditions[[length(...future.conditions) +
[16:25:20.247] 1L]] <<- list(condition = cond, calls = c(sysCalls(from = ...future.frame),
[16:25:20.247] cond$call), session = sessionInformation(),
[16:25:20.247] timestamp = base::Sys.time(), signaled = 0L)
[16:25:20.247] signalCondition(cond)
[16:25:20.247] }
[16:25:20.247] else if (!ignore && TRUE && inherits(cond, "condition")) {
[16:25:20.247] signal <- FALSE && inherits(cond, character(0))
[16:25:20.247] ...future.conditions[[length(...future.conditions) +
[16:25:20.247] 1L]] <<- list(condition = cond, signaled = base::as.integer(signal))
[16:25:20.247] if (FALSE && !signal) {
[16:25:20.247] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:20.247] {
[16:25:20.247] inherits <- base::inherits
[16:25:20.247] invokeRestart <- base::invokeRestart
[16:25:20.247] is.null <- base::is.null
[16:25:20.247] muffled <- FALSE
[16:25:20.247] if (inherits(cond, "message")) {
[16:25:20.247] muffled <- grepl(pattern, "muffleMessage")
[16:25:20.247] if (muffled)
[16:25:20.247] invokeRestart("muffleMessage")
[16:25:20.247] }
[16:25:20.247] else if (inherits(cond, "warning")) {
[16:25:20.247] muffled <- grepl(pattern, "muffleWarning")
[16:25:20.247] if (muffled)
[16:25:20.247] invokeRestart("muffleWarning")
[16:25:20.247] }
[16:25:20.247] else if (inherits(cond, "condition")) {
[16:25:20.247] if (!is.null(pattern)) {
[16:25:20.247] computeRestarts <- base::computeRestarts
[16:25:20.247] grepl <- base::grepl
[16:25:20.247] restarts <- computeRestarts(cond)
[16:25:20.247] for (restart in restarts) {
[16:25:20.247] name <- restart$name
[16:25:20.247] if (is.null(name))
[16:25:20.247] next
[16:25:20.247] if (!grepl(pattern, name))
[16:25:20.247] next
[16:25:20.247] invokeRestart(restart)
[16:25:20.247] muffled <- TRUE
[16:25:20.247] break
[16:25:20.247] }
[16:25:20.247] }
[16:25:20.247] }
[16:25:20.247] invisible(muffled)
[16:25:20.247] }
[16:25:20.247] muffleCondition(cond, pattern = "^muffle")
[16:25:20.247] }
[16:25:20.247] }
[16:25:20.247] else {
[16:25:20.247] if (TRUE) {
[16:25:20.247] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:20.247] {
[16:25:20.247] inherits <- base::inherits
[16:25:20.247] invokeRestart <- base::invokeRestart
[16:25:20.247] is.null <- base::is.null
[16:25:20.247] muffled <- FALSE
[16:25:20.247] if (inherits(cond, "message")) {
[16:25:20.247] muffled <- grepl(pattern, "muffleMessage")
[16:25:20.247] if (muffled)
[16:25:20.247] invokeRestart("muffleMessage")
[16:25:20.247] }
[16:25:20.247] else if (inherits(cond, "warning")) {
[16:25:20.247] muffled <- grepl(pattern, "muffleWarning")
[16:25:20.247] if (muffled)
[16:25:20.247] invokeRestart("muffleWarning")
[16:25:20.247] }
[16:25:20.247] else if (inherits(cond, "condition")) {
[16:25:20.247] if (!is.null(pattern)) {
[16:25:20.247] computeRestarts <- base::computeRestarts
[16:25:20.247] grepl <- base::grepl
[16:25:20.247] restarts <- computeRestarts(cond)
[16:25:20.247] for (restart in restarts) {
[16:25:20.247] name <- restart$name
[16:25:20.247] if (is.null(name))
[16:25:20.247] next
[16:25:20.247] if (!grepl(pattern, name))
[16:25:20.247] next
[16:25:20.247] invokeRestart(restart)
[16:25:20.247] muffled <- TRUE
[16:25:20.247] break
[16:25:20.247] }
[16:25:20.247] }
[16:25:20.247] }
[16:25:20.247] invisible(muffled)
[16:25:20.247] }
[16:25:20.247] muffleCondition(cond, pattern = "^muffle")
[16:25:20.247] }
[16:25:20.247] }
[16:25:20.247] }
[16:25:20.247] }))
[16:25:20.247] }, error = function(ex) {
[16:25:20.247] base::structure(base::list(value = NULL, visible = NULL,
[16:25:20.247] conditions = ...future.conditions, rng = !identical(base::globalenv()$.Random.seed,
[16:25:20.247] ...future.rng), started = ...future.startTime,
[16:25:20.247] finished = Sys.time(), session_uuid = NA_character_,
[16:25:20.247] version = "1.8"), class = "FutureResult")
[16:25:20.247] }, finally = {
[16:25:20.247] if (!identical(...future.workdir, getwd()))
[16:25:20.247] setwd(...future.workdir)
[16:25:20.247] {
[16:25:20.247] if (identical(getOption("nwarnings"), ...future.oldOptions$nwarnings)) {
[16:25:20.247] ...future.oldOptions$nwarnings <- NULL
[16:25:20.247] }
[16:25:20.247] base::options(...future.oldOptions)
[16:25:20.247] if (.Platform$OS.type == "windows") {
[16:25:20.247] old_names <- names(...future.oldEnvVars)
[16:25:20.247] envs <- base::Sys.getenv()
[16:25:20.247] names <- names(envs)
[16:25:20.247] common <- intersect(names, old_names)
[16:25:20.247] added <- setdiff(names, old_names)
[16:25:20.247] removed <- setdiff(old_names, names)
[16:25:20.247] changed <- common[...future.oldEnvVars[common] !=
[16:25:20.247] envs[common]]
[16:25:20.247] NAMES <- toupper(changed)
[16:25:20.247] args <- list()
[16:25:20.247] for (kk in seq_along(NAMES)) {
[16:25:20.247] name <- changed[[kk]]
[16:25:20.247] NAME <- NAMES[[kk]]
[16:25:20.247] if (name != NAME && is.element(NAME, old_names))
[16:25:20.247] next
[16:25:20.247] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:20.247] }
[16:25:20.247] NAMES <- toupper(added)
[16:25:20.247] for (kk in seq_along(NAMES)) {
[16:25:20.247] name <- added[[kk]]
[16:25:20.247] NAME <- NAMES[[kk]]
[16:25:20.247] if (name != NAME && is.element(NAME, old_names))
[16:25:20.247] next
[16:25:20.247] args[[name]] <- ""
[16:25:20.247] }
[16:25:20.247] NAMES <- toupper(removed)
[16:25:20.247] for (kk in seq_along(NAMES)) {
[16:25:20.247] name <- removed[[kk]]
[16:25:20.247] NAME <- NAMES[[kk]]
[16:25:20.247] if (name != NAME && is.element(NAME, old_names))
[16:25:20.247] next
[16:25:20.247] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:20.247] }
[16:25:20.247] if (length(args) > 0)
[16:25:20.247] base::do.call(base::Sys.setenv, args = args)
[16:25:20.247] args <- names <- old_names <- NAMES <- envs <- common <- added <- removed <- NULL
[16:25:20.247] }
[16:25:20.247] else {
[16:25:20.247] base::do.call(base::Sys.setenv, args = base::as.list(...future.oldEnvVars))
[16:25:20.247] }
[16:25:20.247] {
[16:25:20.247] if (base::length(...future.futureOptionsAdded) >
[16:25:20.247] 0L) {
[16:25:20.247] opts <- base::vector("list", length = base::length(...future.futureOptionsAdded))
[16:25:20.247] base::names(opts) <- ...future.futureOptionsAdded
[16:25:20.247] base::options(opts)
[16:25:20.247] }
[16:25:20.247] {
[16:25:20.247] NULL
[16:25:20.247] options(future.plan = NULL)
[16:25:20.247] if (is.na(NA_character_))
[16:25:20.247] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:20.247] else Sys.setenv(R_FUTURE_PLAN = NA_character_)
[16:25:20.247] future::plan(...future.strategy.old, .cleanup = FALSE,
[16:25:20.247] .init = FALSE)
[16:25:20.247] }
[16:25:20.247] }
[16:25:20.247] }
[16:25:20.247] })
[16:25:20.247] if (TRUE) {
[16:25:20.247] base::sink(type = "output", split = FALSE)
[16:25:20.247] if (TRUE) {
[16:25:20.247] ...future.result$stdout <- base::rawToChar(base::rawConnectionValue(...future.stdout))
[16:25:20.247] }
[16:25:20.247] else {
[16:25:20.247] ...future.result["stdout"] <- base::list(NULL)
[16:25:20.247] }
[16:25:20.247] base::close(...future.stdout)
[16:25:20.247] ...future.stdout <- NULL
[16:25:20.247] }
[16:25:20.247] ...future.result$conditions <- ...future.conditions
[16:25:20.247] ...future.result$finished <- base::Sys.time()
[16:25:20.247] ...future.result
[16:25:20.247] }
[16:25:20.256] plan(): plan_init() of 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function' ... DONE
[16:25:20.256] plan(): nbrOfWorkers() = 2
> pid %<-% { Sys.getpid() }
[16:25:20.258] getGlobalsAndPackages() ...
[16:25:20.258] Searching for globals...
[16:25:20.260] - globals found: [2] '{', 'Sys.getpid'
[16:25:20.260] Searching for globals ... DONE
[16:25:20.260] Resolving globals: FALSE
[16:25:20.261]
[16:25:20.261]
[16:25:20.261] getGlobalsAndPackages() ... DONE
[16:25:20.262] run() for 'Future' ...
[16:25:20.262] - state: 'created'
[16:25:20.262] - Future backend: 'FutureStrategy', 'mirai_multisession', 'mirai_cluster', 'mirai', 'multiprocess', 'future', 'function'
[16:25:20.266] - Future class: 'MiraiFuture', 'MultiprocessFuture', 'Future', 'environment'
[16:25:20.266] - Copy elements of temporary 'MiraiFuture' to final 'Future' object ...
[16:25:20.266] - Field: 'label'
[16:25:20.267] - Field: 'local'
[16:25:20.267] - Field: 'owner'
[16:25:20.267] - Field: 'envir'
[16:25:20.267] - Field: 'packages'
[16:25:20.268] - Field: 'gc'
[16:25:20.268] - Field: 'conditions'
[16:25:20.268] - Field: 'expr'
[16:25:20.268] - Field: 'uuid'
[16:25:20.268] - Field: 'seed'
[16:25:20.269] - Field: 'version'
[16:25:20.269] - Field: 'result'
[16:25:20.269] - Field: 'asynchronous'
[16:25:20.269] - Field: 'calls'
[16:25:20.270] - Field: 'globals'
[16:25:20.270] - Field: 'stdout'
[16:25:20.270] - Field: 'earlySignal'
[16:25:20.270] - Field: 'lazy'
[16:25:20.271] - Field: 'state'
[16:25:20.271] - Field: '.cluster'
[16:25:20.271] - Copy elements of temporary 'MiraiFuture' to final 'Future' object ... done
[16:25:20.271] - Launch lazy future ...
[16:25:20.272] Packages needed by the future expression (n = 0): <none>
[16:25:20.272] Packages needed by future strategies (n = 0): <none>
[16:25:20.273] {
[16:25:20.273] {
[16:25:20.273] {
[16:25:20.273] ...future.startTime <- base::Sys.time()
[16:25:20.273] {
[16:25:20.273] {
[16:25:20.273] {
[16:25:20.273] base::local({
[16:25:20.273] has_future <- base::requireNamespace("future",
[16:25:20.273] quietly = TRUE)
[16:25:20.273] if (has_future) {
[16:25:20.273] ns <- base::getNamespace("future")
[16:25:20.273] version <- ns[[".package"]][["version"]]
[16:25:20.273] if (is.null(version))
[16:25:20.273] version <- utils::packageVersion("future")
[16:25:20.273] }
[16:25:20.273] else {
[16:25:20.273] version <- NULL
[16:25:20.273] }
[16:25:20.273] if (!has_future || version < "1.8.0") {
[16:25:20.273] info <- base::c(r_version = base::gsub("R version ",
[16:25:20.273] "", base::R.version$version.string),
[16:25:20.273] platform = base::sprintf("%s (%s-bit)",
[16:25:20.273] base::R.version$platform, 8 * base::.Machine$sizeof.pointer),
[16:25:20.273] os = base::paste(base::Sys.info()[base::c("sysname",
[16:25:20.273] "release", "version")], collapse = " "),
[16:25:20.273] hostname = base::Sys.info()[["nodename"]])
[16:25:20.273] info <- base::sprintf("%s: %s", base::names(info),
[16:25:20.273] info)
[16:25:20.273] info <- base::paste(info, collapse = "; ")
[16:25:20.273] if (!has_future) {
[16:25:20.273] msg <- base::sprintf("Package 'future' is not installed on worker (%s)",
[16:25:20.273] info)
[16:25:20.273] }
[16:25:20.273] else {
[16:25:20.273] msg <- base::sprintf("Package 'future' on worker (%s) must be of version >= 1.8.0: %s",
[16:25:20.273] info, version)
[16:25:20.273] }
[16:25:20.273] base::stop(msg)
[16:25:20.273] }
[16:25:20.273] })
[16:25:20.273] }
[16:25:20.273] ...future.strategy.old <- future::plan("list")
[16:25:20.273] options(future.plan = NULL)
[16:25:20.273] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:20.273] future::plan("default", .cleanup = FALSE, .init = FALSE)
[16:25:20.273] }
[16:25:20.273] ...future.workdir <- getwd()
[16:25:20.273] }
[16:25:20.273] ...future.oldOptions <- base::as.list(base::.Options)
[16:25:20.273] ...future.oldEnvVars <- base::Sys.getenv()
[16:25:20.273] }
[16:25:20.273] base::options(future.startup.script = FALSE, future.globals.onMissing = NULL,
[16:25:20.273] future.globals.maxSize = NULL, future.globals.method = NULL,
[16:25:20.273] future.globals.onMissing = NULL, future.globals.onReference = NULL,
[16:25:20.273] future.globals.resolve = NULL, future.resolve.recursive = NULL,
[16:25:20.273] future.rng.onMisuse = NULL, future.rng.onMisuse.keepFuture = NULL,
[16:25:20.273] future.stdout.windows.reencode = NULL, width = 80L)
[16:25:20.273] ...future.futureOptionsAdded <- base::setdiff(base::names(base::.Options),
[16:25:20.273] base::names(...future.oldOptions))
[16:25:20.273] }
[16:25:20.273] if (FALSE) {
[16:25:20.273] }
[16:25:20.273] else {
[16:25:20.273] if (TRUE) {
[16:25:20.273] ...future.stdout <- base::rawConnection(base::raw(0L),
[16:25:20.273] open = "w")
[16:25:20.273] }
[16:25:20.273] else {
[16:25:20.273] ...future.stdout <- base::file(base::switch(.Platform$OS.type,
[16:25:20.273] windows = "NUL", "/dev/null"), open = "w")
[16:25:20.273] }
[16:25:20.273] base::sink(...future.stdout, type = "output", split = FALSE)
[16:25:20.273] base::on.exit(if (!base::is.null(...future.stdout)) {
[16:25:20.273] base::sink(type = "output", split = FALSE)
[16:25:20.273] base::close(...future.stdout)
[16:25:20.273] }, add = TRUE)
[16:25:20.273] }
[16:25:20.273] ...future.frame <- base::sys.nframe()
[16:25:20.273] ...future.conditions <- base::list()
[16:25:20.273] ...future.rng <- base::globalenv()$.Random.seed
[16:25:20.273] if (FALSE) {
[16:25:20.273] ...future.globalenv.names <- c(base::names(base::.GlobalEnv),
[16:25:20.273] "...future.value", "...future.globalenv.names", ".Random.seed")
[16:25:20.273] }
[16:25:20.273] ...future.result <- base::tryCatch({
[16:25:20.273] base::withCallingHandlers({
[16:25:20.273] ...future.value <- base::withVisible(base::local({
[16:25:20.273] Sys.getpid()
[16:25:20.273] }))
[16:25:20.273] future::FutureResult(value = ...future.value$value,
[16:25:20.273] visible = ...future.value$visible, rng = !identical(base::globalenv()$.Random.seed,
[16:25:20.273] ...future.rng), globalenv = if (FALSE)
[16:25:20.273] list(added = base::setdiff(base::names(base::.GlobalEnv),
[16:25:20.273] ...future.globalenv.names))
[16:25:20.273] else NULL, started = ...future.startTime, version = "1.8")
[16:25:20.273] }, condition = base::local({
[16:25:20.273] c <- base::c
[16:25:20.273] inherits <- base::inherits
[16:25:20.273] invokeRestart <- base::invokeRestart
[16:25:20.273] length <- base::length
[16:25:20.273] list <- base::list
[16:25:20.273] seq.int <- base::seq.int
[16:25:20.273] signalCondition <- base::signalCondition
[16:25:20.273] sys.calls <- base::sys.calls
[16:25:20.273] `[[` <- base::`[[`
[16:25:20.273] `+` <- base::`+`
[16:25:20.273] `<<-` <- base::`<<-`
[16:25:20.273] sysCalls <- function(calls = sys.calls(), from = 1L) {
[16:25:20.273] calls[seq.int(from = from + 12L, to = length(calls) -
[16:25:20.273] 3L)]
[16:25:20.273] }
[16:25:20.273] function(cond) {
[16:25:20.273] is_error <- inherits(cond, "error")
[16:25:20.273] ignore <- !is_error && !is.null(NULL) && inherits(cond,
[16:25:20.273] NULL)
[16:25:20.273] if (is_error) {
[16:25:20.273] sessionInformation <- function() {
[16:25:20.273] list(r = base::R.Version(), locale = base::Sys.getlocale(),
[16:25:20.273] rngkind = base::RNGkind(), namespaces = base::loadedNamespaces(),
[16:25:20.273] search = base::search(), system = base::Sys.info())
[16:25:20.273] }
[16:25:20.273] ...future.conditions[[length(...future.conditions) +
[16:25:20.273] 1L]] <<- list(condition = cond, calls = c(sysCalls(from = ...future.frame),
[16:25:20.273] cond$call), session = sessionInformation(),
[16:25:20.273] timestamp = base::Sys.time(), signaled = 0L)
[16:25:20.273] signalCondition(cond)
[16:25:20.273] }
[16:25:20.273] else if (!ignore && TRUE && inherits(cond, "condition")) {
[16:25:20.273] signal <- FALSE && inherits(cond, character(0))
[16:25:20.273] ...future.conditions[[length(...future.conditions) +
[16:25:20.273] 1L]] <<- list(condition = cond, signaled = base::as.integer(signal))
[16:25:20.273] if (FALSE && !signal) {
[16:25:20.273] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:20.273] {
[16:25:20.273] inherits <- base::inherits
[16:25:20.273] invokeRestart <- base::invokeRestart
[16:25:20.273] is.null <- base::is.null
[16:25:20.273] muffled <- FALSE
[16:25:20.273] if (inherits(cond, "message")) {
[16:25:20.273] muffled <- grepl(pattern, "muffleMessage")
[16:25:20.273] if (muffled)
[16:25:20.273] invokeRestart("muffleMessage")
[16:25:20.273] }
[16:25:20.273] else if (inherits(cond, "warning")) {
[16:25:20.273] muffled <- grepl(pattern, "muffleWarning")
[16:25:20.273] if (muffled)
[16:25:20.273] invokeRestart("muffleWarning")
[16:25:20.273] }
[16:25:20.273] else if (inherits(cond, "condition")) {
[16:25:20.273] if (!is.null(pattern)) {
[16:25:20.273] computeRestarts <- base::computeRestarts
[16:25:20.273] grepl <- base::grepl
[16:25:20.273] restarts <- computeRestarts(cond)
[16:25:20.273] for (restart in restarts) {
[16:25:20.273] name <- restart$name
[16:25:20.273] if (is.null(name))
[16:25:20.273] next
[16:25:20.273] if (!grepl(pattern, name))
[16:25:20.273] next
[16:25:20.273] invokeRestart(restart)
[16:25:20.273] muffled <- TRUE
[16:25:20.273] break
[16:25:20.273] }
[16:25:20.273] }
[16:25:20.273] }
[16:25:20.273] invisible(muffled)
[16:25:20.273] }
[16:25:20.273] muffleCondition(cond, pattern = "^muffle")
[16:25:20.273] }
[16:25:20.273] }
[16:25:20.273] else {
[16:25:20.273] if (TRUE) {
[16:25:20.273] muffleCondition <- function (cond, pattern = "^muffle")
[16:25:20.273] {
[16:25:20.273] inherits <- base::inherits
[16:25:20.273] invokeRestart <- base::invokeRestart
[16:25:20.273] is.null <- base::is.null
[16:25:20.273] muffled <- FALSE
[16:25:20.273] if (inherits(cond, "message")) {
[16:25:20.273] muffled <- grepl(pattern, "muffleMessage")
[16:25:20.273] if (muffled)
[16:25:20.273] invokeRestart("muffleMessage")
[16:25:20.273] }
[16:25:20.273] else if (inherits(cond, "warning")) {
[16:25:20.273] muffled <- grepl(pattern, "muffleWarning")
[16:25:20.273] if (muffled)
[16:25:20.273] invokeRestart("muffleWarning")
[16:25:20.273] }
[16:25:20.273] else if (inherits(cond, "condition")) {
[16:25:20.273] if (!is.null(pattern)) {
[16:25:20.273] computeRestarts <- base::computeRestarts
[16:25:20.273] grepl <- base::grepl
[16:25:20.273] restarts <- computeRestarts(cond)
[16:25:20.273] for (restart in restarts) {
[16:25:20.273] name <- restart$name
[16:25:20.273] if (is.null(name))
[16:25:20.273] next
[16:25:20.273] if (!grepl(pattern, name))
[16:25:20.273] next
[16:25:20.273] invokeRestart(restart)
[16:25:20.273] muffled <- TRUE
[16:25:20.273] break
[16:25:20.273] }
[16:25:20.273] }
[16:25:20.273] }
[16:25:20.273] invisible(muffled)
[16:25:20.273] }
[16:25:20.273] muffleCondition(cond, pattern = "^muffle")
[16:25:20.273] }
[16:25:20.273] }
[16:25:20.273] }
[16:25:20.273] }))
[16:25:20.273] }, error = function(ex) {
[16:25:20.273] base::structure(base::list(value = NULL, visible = NULL,
[16:25:20.273] conditions = ...future.conditions, rng = !identical(base::globalenv()$.Random.seed,
[16:25:20.273] ...future.rng), started = ...future.startTime,
[16:25:20.273] finished = Sys.time(), session_uuid = NA_character_,
[16:25:20.273] version = "1.8"), class = "FutureResult")
[16:25:20.273] }, finally = {
[16:25:20.273] if (!identical(...future.workdir, getwd()))
[16:25:20.273] setwd(...future.workdir)
[16:25:20.273] {
[16:25:20.273] if (identical(getOption("nwarnings"), ...future.oldOptions$nwarnings)) {
[16:25:20.273] ...future.oldOptions$nwarnings <- NULL
[16:25:20.273] }
[16:25:20.273] base::options(...future.oldOptions)
[16:25:20.273] if (.Platform$OS.type == "windows") {
[16:25:20.273] old_names <- names(...future.oldEnvVars)
[16:25:20.273] envs <- base::Sys.getenv()
[16:25:20.273] names <- names(envs)
[16:25:20.273] common <- intersect(names, old_names)
[16:25:20.273] added <- setdiff(names, old_names)
[16:25:20.273] removed <- setdiff(old_names, names)
[16:25:20.273] changed <- common[...future.oldEnvVars[common] !=
[16:25:20.273] envs[common]]
[16:25:20.273] NAMES <- toupper(changed)
[16:25:20.273] args <- list()
[16:25:20.273] for (kk in seq_along(NAMES)) {
[16:25:20.273] name <- changed[[kk]]
[16:25:20.273] NAME <- NAMES[[kk]]
[16:25:20.273] if (name != NAME && is.element(NAME, old_names))
[16:25:20.273] next
[16:25:20.273] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:20.273] }
[16:25:20.273] NAMES <- toupper(added)
[16:25:20.273] for (kk in seq_along(NAMES)) {
[16:25:20.273] name <- added[[kk]]
[16:25:20.273] NAME <- NAMES[[kk]]
[16:25:20.273] if (name != NAME && is.element(NAME, old_names))
[16:25:20.273] next
[16:25:20.273] args[[name]] <- ""
[16:25:20.273] }
[16:25:20.273] NAMES <- toupper(removed)
[16:25:20.273] for (kk in seq_along(NAMES)) {
[16:25:20.273] name <- removed[[kk]]
[16:25:20.273] NAME <- NAMES[[kk]]
[16:25:20.273] if (name != NAME && is.element(NAME, old_names))
[16:25:20.273] next
[16:25:20.273] args[[name]] <- ...future.oldEnvVars[[name]]
[16:25:20.273] }
[16:25:20.273] if (length(args) > 0)
[16:25:20.273] base::do.call(base::Sys.setenv, args = args)
[16:25:20.273] args <- names <- old_names <- NAMES <- envs <- common <- added <- removed <- NULL
[16:25:20.273] }
[16:25:20.273] else {
[16:25:20.273] base::do.call(base::Sys.setenv, args = base::as.list(...future.oldEnvVars))
[16:25:20.273] }
[16:25:20.273] {
[16:25:20.273] if (base::length(...future.futureOptionsAdded) >
[16:25:20.273] 0L) {
[16:25:20.273] opts <- base::vector("list", length = base::length(...future.futureOptionsAdded))
[16:25:20.273] base::names(opts) <- ...future.futureOptionsAdded
[16:25:20.273] base::options(opts)
[16:25:20.273] }
[16:25:20.273] {
[16:25:20.273] NULL
[16:25:20.273] options(future.plan = NULL)
[16:25:20.273] if (is.na(NA_character_))
[16:25:20.273] Sys.unsetenv("R_FUTURE_PLAN")
[16:25:20.273] else Sys.setenv(R_FUTURE_PLAN = NA_character_)
[16:25:20.273] future::plan(...future.strategy.old, .cleanup = FALSE,
[16:25:20.273] .init = FALSE)
[16:25:20.273] }
[16:25:20.273] }
[16:25:20.273] }
[16:25:20.273] })
[16:25:20.273] if (TRUE) {
[16:25:20.273] base::sink(type = "output", split = FALSE)
[16:25:20.273] if (TRUE) {
[16:25:20.273] ...future.result$stdout <- base::rawToChar(base::rawConnectionValue(...future.stdout))
[16:25:20.273] }
[16:25:20.273] else {
[16:25:20.273] ...future.result["stdout"] <- base::list(NULL)
[16:25:20.273] }
[16:25:20.273] base::close(...future.stdout)
[16:25:20.273] ...future.stdout <- NULL
[16:25:20.273] }
[16:25:20.273] ...future.result$conditions <- ...future.conditions
[16:25:20.273] ...future.result$finished <- base::Sys.time()
[16:25:20.273] ...future.result
[16:25:20.273] }
[16:25:20.282] - Launch lazy future ... done
[16:25:20.282] run() for 'MiraiFuture' ... done
> print(pid)
[1] 187900
> stopifnot(pid != mpid)
>
>
> message("*** plan() ... DONE")
*** plan() ... DONE
>
> source("incl/end.R")
>
> proc.time()
user system elapsed
0.56 0.15 1.35
Flavor: r-devel-windows-x86_64
Current CRAN status: OK: 12
Current CRAN status: OK: 13
Current CRAN status: OK: 13
Current CRAN status: OK: 13
Current CRAN status: OK: 13
Current CRAN status: OK: 13
Current CRAN status: ERROR: 1, OK: 11
Version: 0.6.0
Check: re-building of vignette outputs
Result: ERROR
Error(s) in re-building vignettes:
...
--- re-building ‘profmem.md.rsp’ using rsp
R.utils v2.12.3 (2023-11-18 01:00:02 UTC) successfully loaded. See ?R.utils for help.
Attaching package: ‘R.utils’
The following object is masked from ‘package:utils’:
timestamp
The following objects are masked from ‘package:base’:
cat, commandArgs, getOption, isOpen, nullfile, parse, use, warnings
Error: processing vignette 'profmem.md.rsp' failed with diagnostics:
there is no package called ‘microbenchmark’
--- failed re-building ‘profmem.md.rsp’
SUMMARY: processing the following file failed:
‘profmem.md.rsp’
Error: Vignette re-building failed.
Execution halted
Flavor: r-release-macos-arm64
Current CRAN status: OK: 12
Current CRAN status: OK: 13
Current CRAN status: NOTE: 9, OK: 3
Version: 0.16.0
Check: Rd files
Result: NOTE
checkRd: (-1) R.cache-package.Rd:28-30: Lost braces in \itemize; meant \describe ?
checkRd: (-1) R.cache-package.Rd:31-34: Lost braces in \itemize; meant \describe ?
Flavors: r-devel-linux-x86_64-debian-clang, r-devel-linux-x86_64-debian-gcc, r-devel-linux-x86_64-fedora-clang, r-devel-linux-x86_64-fedora-gcc, r-devel-windows-x86_64, r-patched-linux-x86_64, r-release-linux-x86_64, r-release-macos-arm64, r-release-windows-x86_64
Current CRAN status: OK: 13
Current CRAN status: OK: 13
Current CRAN status: OK: 13
Current CRAN status: NOTE: 9, OK: 3
Version: 3.7.0
Check: Rd files
Result: NOTE
checkRd: (-1) setOption.Matlab.Rd:37-39: Lost braces in \itemize; meant \describe ?
checkRd: (-1) setOption.Matlab.Rd:40-41: Lost braces in \itemize; meant \describe ?
Flavors: r-devel-linux-x86_64-debian-clang, r-devel-linux-x86_64-debian-gcc, r-devel-linux-x86_64-fedora-clang, r-devel-linux-x86_64-fedora-gcc, r-devel-windows-x86_64, r-patched-linux-x86_64, r-release-linux-x86_64, r-release-macos-arm64, r-release-windows-x86_64
Current CRAN status: OK: 12
Current CRAN status: OK: 13
Current CRAN status: OK: 13
Current CRAN status: OK: 12
Current CRAN status: OK: 13
Current CRAN status: OK: 12
Current CRAN status: NOTE: 9, OK: 3
Version: 0.10.1
Check: Rd files
Result: NOTE
checkRd: (-1) TopDom.Rd:21: Lost braces; missing escapes or markup?
21 | Recommended range is in {5, ..., 20}.}
| ^
Flavors: r-devel-linux-x86_64-debian-clang, r-devel-linux-x86_64-debian-gcc, r-devel-linux-x86_64-fedora-clang, r-devel-linux-x86_64-fedora-gcc, r-devel-windows-x86_64, r-patched-linux-x86_64, r-release-linux-x86_64, r-release-macos-arm64, r-release-windows-x86_64