R Under development (unstable) (2025-07-28 r88462 ucrt) -- "Unsuffered Consequences" Copyright (C) 2025 The R Foundation for Statistical Computing Platform: x86_64-w64-mingw32/x64 R is free software and comes with ABSOLUTELY NO WARRANTY. You are welcome to redistribute it under certain conditions. Type 'license()' or 'licence()' for distribution details. R is a collaborative project with many contributors. Type 'contributors()' for more information and 'citation()' on how to cite R or R packages in publications. Type 'demo()' for some demos, 'help()' for on-line help, or 'help.start()' for an HTML browser interface to help. Type 'q()' to quit R. > ## This runs testme test script inst/testme/test-cluster-connection-clashes.R > ## Don't edit - it was autogenerated by inst/testme/deploy.R > future:::testme("cluster-connection-clashes") Test 'cluster-connection-clashes' ... Sourcing 9 prologue scripts ... 01/09 prologue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_prologue/001.load.R' 02/09 prologue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_prologue/002.record-state.R' 03/09 prologue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_prologue/030.imports.R' 04/09 prologue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_prologue/050.utils.R' 05/09 prologue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_prologue/090.context.R' 06/09 prologue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_prologue/090.options.R' 07/09 prologue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_prologue/091.envvars.R' 08/09 prologue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_prologue/099.future-setup.R' 09/09 prologue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_prologue/995.detrius-connections.R' Sourcing 9 prologue scripts ... done Running test script: 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/test-cluster-connection-clashes.R' > library(future) [12:32:21.546] Option 'future.startup.script': TRUE [12:32:21.547] Future startup scripts considered: '.future.R', '~/.future.R' [12:32:21.548] Future startup scripts found: > message("all.equal() for connection ...") all.equal() for connection ... > con1 <- rawConnection(raw()) > close(con1) > con2 <- rawConnection(raw()) > close(con2) > stopifnot(!isTRUE(all.equal(con1, con2))) > message("all.equal() for connection ... done") all.equal() for connection ... done > message("all.equal() for cluster backend ...") all.equal() for cluster backend ... > for (kk in 1:3) { + message("Iteration #", kk) + cl <- parallel::makeCluster(1) + plan(cluster, workers = cl) + fs <- lapply(1:2, FU .... [TRUNCATED] Iteration #1 [12:32:21.883] plan(<'name'>, .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:21.884] | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = NA, init = TRUE) ... [12:32:21.885] | : all.equal() for FutureStrategyList ... [12:32:21.885] | : . New stack: [12:32:21.885] | : . List of 1 [12:32:21.885] | : . $ :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:21.885] | : . ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:21.885] | : . ..- attr(*, "init")= logi TRUE [12:32:21.885] | : . ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:21.885] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:21.885] | : . .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:21.885] | : . ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:21.885] | : . ..- attr(*, "tweaks")=List of 1 [12:32:21.885] | : . .. ..$ workers:List of 1 [12:32:21.885] | : . .. .. ..$ :List of 3 [12:32:21.885] | : . .. .. .. ..$ con : 'sockconn' int 4 [12:32:21.885] | : . .. .. .. .. ..- attr(*, "conn_id")= [12:32:21.885] | : . .. .. .. ..$ host: chr "localhost" [12:32:21.885] | : . .. .. .. ..$ rank: num 0 [12:32:21.885] | : . .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:21.885] | : . .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:21.885] | : . ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:21.885] | : . - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:21.907] | : . Old stack: [12:32:21.907] | : . List of 1 [12:32:21.907] | : . $ :function (..., envir = parent.frame()) [12:32:21.907] | : . ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function" [12:32:21.907] | : . ..- attr(*, "init")= logi TRUE [12:32:21.907] | : . ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf) [12:32:21.907] | : . .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:21.907] | : . ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:21.907] | : . ..- attr(*, "call")= language plan(sequential) [12:32:21.907] | : . - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:21.913] | : . Not identical [12:32:21.913] | : . all.equal() for future ... [12:32:21.914] | : . ' List of 2 [12:32:21.914] | : . ' $ target :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:21.914] | : . ' ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:21.914] | : . ' ..- attr(*, "init")= logi TRUE [12:32:21.914] | : . ' ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:21.914] | : . ' earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:21.914] | : . ' .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:21.914] | : . ' ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:21.914] | : . ' ..- attr(*, "tweaks")=List of 1 [12:32:21.914] | : . ' .. ..$ workers:List of 1 [12:32:21.914] | : . ' .. .. ..$ :List of 3 [12:32:21.914] | : . ' .. .. .. ..$ con : 'sockconn' int 4 [12:32:21.914] | : . ' .. .. .. .. ..- attr(*, "conn_id")= [12:32:21.914] | : . ' .. .. .. ..$ host: chr "localhost" [12:32:21.914] | : . ' .. .. .. ..$ rank: num 0 [12:32:21.914] | : . ' .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:21.914] | : . ' .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:21.914] | : . ' ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:21.914] | : . ' $ current:function (..., envir = parent.frame()) [12:32:21.914] | : . ' ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function" [12:32:21.914] | : . ' ..- attr(*, "init")= logi TRUE [12:32:21.914] | : . ' ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf) [12:32:21.914] | : . ' .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:21.914] | : . ' ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:21.914] | : . ' ..- attr(*, "call")= language plan(sequential) [12:32:21.930] | : . ' Formals differ [12:32:21.930] | : . all.equal() for future ... done [12:32:21.931] | : . Future strategies differ at level 1 [12:32:21.931] | : all.equal() for FutureStrategyList ... done [12:32:21.931] | : plan(): Setting new future backend stack: [12:32:21.932] | : List of future strategies: [12:32:21.932] | : 1. cluster: [12:32:21.932] | : - args: function (..., workers = "") [12:32:21.932] | : - tweaked: TRUE [12:32:21.932] | : - call: plan(cluster, workers = cl) [12:32:21.933] | : List of 1 [12:32:21.933] | : $ :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:21.933] | : ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:21.933] | : ..- attr(*, "init")= logi TRUE [12:32:21.933] | : ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:21.933] | : earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:21.933] | : .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:21.933] | : ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:21.933] | : ..- attr(*, "tweaks")=List of 1 [12:32:21.933] | : .. ..$ workers:List of 1 [12:32:21.933] | : .. .. ..$ :List of 3 [12:32:21.933] | : .. .. .. ..$ con : 'sockconn' int 4 [12:32:21.933] | : .. .. .. .. ..- attr(*, "conn_id")= [12:32:21.933] | : .. .. .. ..$ host: chr "localhost" [12:32:21.933] | : .. .. .. ..$ rank: num 0 [12:32:21.933] | : .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:21.933] | : .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:21.933] | : ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:21.933] | : - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:21.948] | : plan(): plan_cleanup(<'sequential', 'uniprocess', 'future', 'function'>, cleanup = NA) ... [12:32:21.949] | : . plan("next", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:21.949] | : . ' Getting current ("next") strategy: 'FutureStrategy', 'sequential', 'uniprocess', 'future', 'function' [12:32:21.949] | : . plan("next", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:21.950] | : . Legacy shutdown of cluster workers ... [12:32:21.950] | : . ' Stopping existing cluster ... [12:32:21.950] | : . ' , No pre-existing cluster. Skipping [12:32:21.951] | : . ' Stopping existing cluster ... done [12:32:21.951] | : . Legacy shutdown of cluster workers ... done [12:32:21.951] | : plan(): plan_cleanup(<'sequential', 'uniprocess', 'future', 'function'>, cleanup = NA) ... done [12:32:21.952] | : plan(): plan_init() of 'tweaked', 'cluster', 'multiprocess', 'future', 'function' ... [12:32:21.952] | : . function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:21.952] | : . - attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:21.952] | : . - attr(*, "init")= logi TRUE [12:32:21.952] | : . - attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:21.952] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:21.952] | : . ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:21.952] | : . - attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:21.952] | : . - attr(*, "tweaks")=List of 1 [12:32:21.952] | : . ..$ workers:List of 1 [12:32:21.952] | : . .. ..$ :List of 3 [12:32:21.952] | : . .. .. ..$ con : 'sockconn' int 4 [12:32:21.952] | : . .. .. .. ..- attr(*, "conn_id")= [12:32:21.952] | : . .. .. ..$ host: chr "localhost" [12:32:21.952] | : . .. .. ..$ rank: num 0 [12:32:21.952] | : . .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:21.952] | : . .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:21.952] | : . - attr(*, "call")= language plan(cluster, workers = cl) [12:32:21.963] | : . init: TRUE [12:32:21.963] | : . makeFutureBackend() ... [12:32:21.964] | : . ' Backend function: <'NULL'> [12:32:21.964] | : . ' Evaluator tweak arguments: [n=1] [12:32:21.964] | : . ' List of 1 [12:32:21.964] | : . ' $ workers:List of 1 [12:32:21.964] | : . ' ..$ :List of 3 [12:32:21.964] | : . ' .. ..$ con : 'sockconn' int 4 [12:32:21.964] | : . ' .. .. ..- attr(*, "conn_id")= [12:32:21.964] | : . ' .. ..$ host: chr "localhost" [12:32:21.964] | : . ' .. ..$ rank: num 0 [12:32:21.964] | : . ' .. ..- attr(*, "class")= chr "SOCKnode" [12:32:21.964] | : . ' ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:21.971] | : . ' Evaluator formal arguments: [n=1] [12:32:21.971] | : . ' List of 1 [12:32:21.971] | : . ' $ workers:List of 1 [12:32:21.971] | : . ' ..$ :List of 3 [12:32:21.971] | : . ' .. ..$ con : 'sockconn' int 4 [12:32:21.971] | : . ' .. .. ..- attr(*, "conn_id")= [12:32:21.971] | : . ' .. ..$ host: chr "localhost" [12:32:21.971] | : . ' .. ..$ rank: num 0 [12:32:21.971] | : . ' .. ..- attr(*, "class")= chr "SOCKnode" [12:32:21.971] | : . ' ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:21.977] | : . ' Backend factory arguments: [n=1] [12:32:21.977] | : . ' Dotted pair list of 1 [12:32:21.977] | : . ' $ workers:List of 1 [12:32:21.977] | : . ' ..$ :List of 3 [12:32:21.977] | : . ' .. ..$ con : 'sockconn' int 4 [12:32:21.977] | : . ' .. .. ..- attr(*, "conn_id")= [12:32:21.977] | : . ' .. ..$ host: chr "localhost" [12:32:21.977] | : . ' .. ..$ rank: num 0 [12:32:21.977] | : . ' .. ..- attr(*, "class")= chr "SOCKnode" [12:32:21.977] | : . ' ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:21.984] | : . ' ClusterFutureBackend(..., persistent = FALSE, gc = TRUE, earlySignal = TRUE) ... [12:32:21.984] | : . ' , Stopping existing cluster ... [12:32:21.984] | : . ' , ; No pre-existing cluster. Skipping [12:32:21.985] | : . ' , Stopping existing cluster ... done [12:32:21.985] | : . ' , Number of workers: 1 [12:32:21.986] | : . ' , Generated workers UUID [12:32:21.986] | : . ' , Workers UUID: '37e5752128e4483a3ce8b7fda2d6c13d' [12:32:21.987] | : . ' ClusterFutureBackend(..., persistent = FALSE, gc = TRUE, earlySignal = TRUE) ... done [12:32:21.987] | : . ' Backend: <'ClusterFutureBackend', 'MultiprocessFutureBackend', 'FutureBackend', 'environment'> [12:32:21.988] | : . makeFutureBackend() ... done [12:32:21.988] | : plan(): plan_init() of 'tweaked', 'cluster', 'multiprocess', 'future', 'function' ... done [12:32:21.991] | : nbrOfWorkers(NULL) ... [12:32:21.992] | : . List of 4 [12:32:21.992] | : . $ : language plan_set(newStack, skip = .skip, cleanup = .cleanup, init = .init, debug = debug) [12:32:21.992] | : . $ : language with_assert({ nbrOfWorkers <- nbrOfWorkers() ... [12:32:21.992] | : . $ : language nbrOfWorkers() [12:32:21.992] | : . $ : language nbrOfWorkers.NULL() [12:32:21.995] | : . plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:21.996] | : . plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:21.996] | : . Number of workers: 1 [12:32:21.997] | : nbrOfWorkers(NULL) ... done [12:32:21.997] | : plan(): nbrOfWorkers() = 1 [12:32:21.997] | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = NA, init = TRUE) ... done [12:32:21.998] plan(<'name'>, .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:21.998] future(..., label = NULL) ... [12:32:21.998] | lazy: FALSE [12:32:21.999] | stdout: TRUE [12:32:21.999] | conditions: [n=1] 'condition' [12:32:21.999] | gc: FALSE [12:32:21.999] | earlySignal: FALSE [12:32:22.001] | getGlobalsAndPackages() ... [12:32:22.001] | : Searching for globals ... [12:32:22.026] | : . globals found: [3] '[[', 'X', 'i' [12:32:22.026] | : Searching for globals ... done [12:32:22.027] | : Resolving globals: FALSE [12:32:22.027] | : Search for packages associated with the globals ... [12:32:22.028] | : . Packages associated with globals: [1] 'base' [12:32:22.029] | : . Packages: [1] 'base' [12:32:22.029] | : Search for packages associated with the globals ... done [12:32:22.030] | : Packages after dropping 'base': [0] [12:32:22.030] | : globals: [2] 'X', 'i' [12:32:22.030] | : packages: [0] [12:32:22.031] | getGlobalsAndPackages() ... done [12:32:22.032] | run() for 'Future' () ... [12:32:22.033] | : state: 'created' [12:32:22.033] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:22.034] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:22.034] | : Using ClusterFutureBackend ... [12:32:22.034] | : . Number of futures since start: 0 (0 created, 0 launched, 0 finished) [12:32:22.035] | : . Launching futures ... [12:32:22.036] | : . ' launchFuture() for ClusterFutureBackend ... [12:32:22.036] | : . ' , Workers: [n=1] [12:32:22.036] | : . ' , socket cluster with 1 nodes on host 'localhost' [12:32:22.037] | : . ' , FutureRegistry: 'workers-37e5752128e4483a3ce8b7fda2d6c13d' [12:32:22.041] | : . ' , requestWorker() ... [12:32:22.042] | : . ' , ; requestNode() ... [12:32:22.042] | : . ' , ; ` Number of workers: 1 [12:32:22.042] | : . ' , ; ` Polling for a free worker ... [12:32:22.043] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:22.043] | : . ' , ; ` | : Created empty registry 'workers-37e5752128e4483a3ce8b7fda2d6c13d' [12:32:22.043] | : . ' , ; ` | : Listing all futures [12:32:22.043] | : . ' , ; ` | : Number of registered futures: 0 [12:32:22.044] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:22.044] | : . ' , ; ` | Total time: 0 [12:32:22.044] | : . ' , ; ` Polling for a free worker ... done [12:32:22.045] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:22.045] | : . ' , ; ` | Listing all futures [12:32:22.045] | : . ' , ; ` | Number of registered futures: 0 [12:32:22.046] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:22.046] | : . ' , ; ` avail: [n=1] '1' [12:32:22.046] | : . ' , ; ` Index of first available worker: 1 [12:32:22.047] | : . ' , ; ` Validate that the worker is functional ... [12:32:22.048] | : . ' , ; ` | Worker is functional [12:32:22.048] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:22.048] | : . ' , ; ` | : Listing all futures [12:32:22.049] | : . ' , ; ` | : Number of registered futures: 0 [12:32:22.049] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:22.049] | : . ' , ; ` Validate that the worker is functional ... done [12:32:22.050] | : . ' , ; requestNode() ... done [12:32:22.050] | : . ' , ; cluster node index: 1 [12:32:22.050] | : . ' , requestWorker() ... done [12:32:22.051] | : . ' , eraseGlobalEnvironment() ... [12:32:22.204] | : . ' , eraseGlobalEnvironment() ... done [12:32:22.205] | : . ' , launchFuture() ... [12:32:22.205] | : . ' , ; cluster node index: 1 [12:32:22.205] | : . ' , ; getFutureData() ... [12:32:22.206] | : . ' , ; ` getFutureCore() ... [12:32:22.206] | : . ' , ; ` | Packages needed by the future expression (n = 0): [12:32:22.206] | : . ' , ; ` getFutureCore() ... done [12:32:22.207] | : . ' , ; ` getFutureCapture() ... [12:32:22.207] | : . ' , ; ` getFutureCapture() ... done [12:32:22.207] | : . ' , ; ` getFutureContext() ... [12:32:22.208] | : . ' , ; ` | plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:22.208] | : . ' , ; ` | : Getting stack without first backend: [n=0] [12:32:22.208] | : . ' , ; ` | plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:22.208] | : . ' , ; ` | Packages needed by future backend (n = 0): [12:32:22.208] | : . ' , ; ` getFutureContext() ... done [12:32:22.209] | : . ' , ; getFutureData() ... done [12:32:22.210] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... [12:32:22.210] | : . ' , ; ` Appended future to position #1 [12:32:22.210] | : . ' , ; ` Number of registered futures: 1 [12:32:22.211] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... done [12:32:22.211] | : . ' , launchFuture() ... done [12:32:22.211] | : . ' , ClusterFuture started [12:32:22.212] | : . ' launchFuture() for ClusterFutureBackend ... done [12:32:22.212] | : . Launching futures ... done [12:32:22.212] | : . Future launched: 'ClusterFuture', 'MultiprocessFuture', 'Future' [12:32:22.212] | : Using ClusterFutureBackend ... done [12:32:22.213] | run() for 'Future' () ... done [12:32:22.213] future(..., label = NULL) ... done [12:32:22.213] future(..., label = NULL) ... [12:32:22.214] | lazy: FALSE [12:32:22.214] | stdout: TRUE [12:32:22.214] | conditions: [n=1] 'condition' [12:32:22.215] | gc: FALSE [12:32:22.215] | earlySignal: FALSE [12:32:22.215] | getGlobalsAndPackages() ... [12:32:22.216] | : Searching for globals ... [12:32:22.225] | : . globals found: [3] '[[', 'X', 'i' [12:32:22.225] | : Searching for globals ... done [12:32:22.225] | : Resolving globals: FALSE [12:32:22.226] | : Search for packages associated with the globals ... [12:32:22.226] | : . Packages associated with globals: [1] 'base' [12:32:22.227] | : . Packages: [1] 'base' [12:32:22.227] | : Search for packages associated with the globals ... done [12:32:22.228] | : Packages after dropping 'base': [0] [12:32:22.228] | : globals: [2] 'X', 'i' [12:32:22.229] | : packages: [0] [12:32:22.229] | getGlobalsAndPackages() ... done [12:32:22.229] | run() for 'Future' () ... [12:32:22.230] | : state: 'created' [12:32:22.269] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:22.270] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:22.270] | : Using ClusterFutureBackend ... [12:32:22.271] | : . Number of futures since start: 1 (1 created, 1 launched, 0 finished) [12:32:22.271] | : . Launching futures ... [12:32:22.271] | : . ' launchFuture() for ClusterFutureBackend ... [12:32:22.272] | : . ' , Workers: [n=1] [12:32:22.272] | : . ' , socket cluster with 1 nodes on host 'localhost' [12:32:22.273] | : . ' , FutureRegistry: 'workers-37e5752128e4483a3ce8b7fda2d6c13d' [12:32:22.273] | : . ' , requestWorker() ... [12:32:22.274] | : . ' , ; requestNode() ... [12:32:22.274] | : . ' , ; ` Number of workers: 1 [12:32:22.274] | : . ' , ; ` Polling for a free worker ... [12:32:22.275] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:22.275] | : . ' , ; ` | : Listing all futures [12:32:22.275] | : . ' , ; ` | : Number of registered futures: 1 [12:32:22.275] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:22.276] | : . ' , ; ` | Poll #1 (0): usedNodes() = 1, workers = 1 [12:32:22.300] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'collect-first', earlySignal = 1) ... [12:32:22.300] | : . ' , ; ` | : collectValues('workers-37e5752128e4483a3ce8b7fda2d6c13d', firstOnly = TRUE) ... [12:32:22.300] | : . ' , ; ` | : . resolved() ... [12:32:22.301] | : . ' , ; ` | : . ' resolved() for ClusterFuture () ... [12:32:22.302] | : . ' , ; ` | : . ' , Cluster node socket connection: index=4, id=139 [12:32:22.303] | : . ' , ; ` | : . ' , assertValidConnection() ... [12:32:22.303] | : . ' , ; ` | : . ' , ; cluster node index: 1 [12:32:22.303] | : . ' , ; ` | : . ' , assertValidConnection() ... done [12:32:22.304] | : . ' , ; ` | : . ' , receiveMessageFromWorker() for ClusterFuture ... [12:32:22.305] | : . ' , ; ` | : . ' , ; cluster node index: 1 [12:32:22.305] | : . ' , ; ` | : . ' , ; [1] TRUE [12:32:22.305] | : . ' , ; ` | : . ' , ; Received data: [12:32:22.306] | : . ' , ; ` | : . ' , ; List of 5 [12:32:22.306] | : . ' , ; ` | : . ' , ; $ type : chr "VALUE" [12:32:22.306] | : . ' , ; ` | : . ' , ; $ value :List of 16 [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ value : int 1 [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ visible : logi TRUE [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ stdout : chr "" [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ conditions : list() [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ rng : logi FALSE [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ seed : NULL [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ misuseGlobalEnv : NULL [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ misuseConnections :List of 3 [12:32:22.306] | : . ' , ; ` | : . ' , ; .. ..$ added : NULL [12:32:22.306] | : . ' , ; ` | : . ' , ; .. ..$ removed : NULL [12:32:22.306] | : . ' , ; ` | : . ' , ; .. ..$ replaced: NULL [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ misuseDevices : NULL [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ misuseDefaultDevice: list() [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ started : POSIXct[1:1], format: "2025-07-29 12:32:22" [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ finished : POSIXct[1:1], format: "2025-07-29 12:32:22" [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ uuid : chr [1:2] "66e0468231a87fa5a50141bd001890da" "1" [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ session_uuid : chr "90b0ad0ad06d76740e72e872181f8708" [12:32:22.306] | : . ' , ; ` | : . ' , ; .. ..- attr(*, "source")=List of 5 [12:32:22.306] | : . ' , ; ` | : . ' , ; .. .. ..$ host : Named chr "CRANWIN3" [12:32:22.306] | : . ' , ; ` | : . ' , ; .. .. .. ..- attr(*, "names")= chr "COMPUTERNAME" [12:32:22.306] | : . ' , ; ` | : . ' , ; .. .. ..$ info : Named chr [1:9] "Windows" "Server x64" "build 20348" "CRANWIN3" ... [12:32:22.306] | : . ' , ; ` | : . ' , ; .. .. .. ..- attr(*, "names")= chr [1:9] "sysname" "release" "version" "nodename" ... [12:32:22.306] | : . ' , ; ` | : . ' , ; .. .. ..$ pid : int 104460 [12:32:22.306] | : . ' , ; ` | : . ' , ; .. .. ..$ time : POSIXct[1:1], format: "2025-07-29 12:32:22" [12:32:22.306] | : . ' , ; ` | : . ' , ; .. .. ..$ random: int 2147483647 [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ r_info :List of 4 [12:32:22.306] | : . ' , ; ` | : . ' , ; .. ..$ version :Classes 'R_system_version', 'package_version', 'numeric_version' hidden list of 1 [12:32:22.306] | : . ' , ; ` | : . ' , ; .. .. ..$ : int [1:3] 4 6 0 [12:32:22.306] | : . ' , ; ` | : . ' , ; .. ..$ os : chr "windows" [12:32:22.306] | : . ' , ; ` | : . ' , ; .. ..$ os_name : chr "Windows" [12:32:22.306] | : . ' , ; ` | : . ' , ; .. ..$ captures_utf8: logi TRUE [12:32:22.306] | : . ' , ; ` | : . ' , ; ..$ version : chr "1.8" [12:32:22.306] | : . ' , ; ` | : . ' , ; ..- attr(*, "class")= chr "FutureResult" [12:32:22.306] | : . ' , ; ` | : . ' , ; $ success: logi TRUE [12:32:22.306] | : . ' , ; ` | : . ' , ; $ time : 'proc_time' Named num [1:5] 0.06 0.02 0.08 NA NA [12:32:22.306] | : . ' , ; ` | : . ' , ; ..- attr(*, "names")= chr [1:5] "user.self" "sys.self" "elapsed" "user.child" ... [12:32:22.306] | : . ' , ; ` | : . ' , ; $ tag : NULL [12:32:22.369] | : . ' , ; ` | : . ' , ; Received FutureResult [12:32:22.369] | : . ' , ; ` | : . ' , ; FutureResult: [12:32:22.369] | : . ' , ; ` | : . ' , ; value: 'integer' [12:32:22.369] | : . ' , ; ` | : . ' , ; visible: TRUE [12:32:22.369] | : . ' , ; ` | : . ' , ; stdout: character [12:32:22.369] | : . ' , ; ` | : . ' , ; conditions: [n = 0] [12:32:22.369] | : . ' , ; ` | : . ' , ; RNG used: FALSE [12:32:22.369] | : . ' , ; ` | : . ' , ; duration: 0.0829761 secs (started 2025-07-29 12:32:22.212996) [12:32:22.369] | : . ' , ; ` | : . ' , ; version: 1.8 [12:32:22.370] | : . ' , ; ` | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... [12:32:22.375] | : . ' , ; ` | : . ' , ; ` Removed future from position #1 [12:32:22.376] | : . ' , ; ` | : . ' , ; ` Number of registered futures: 0 [12:32:22.376] | : . ' , ; ` | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... done [12:32:22.376] | : . ' , ; ` | : . ' , ; Erased future from future backend [12:32:22.377] | : . ' , ; ` | : . ' , ; result() for ClusterFuture ... [12:32:22.378] | : . ' , ; ` | : . ' , ; ` result already collected: FutureResult [12:32:22.378] | : . ' , ; ` | : . ' , ; result() for ClusterFuture ... done [12:32:22.378] | : . ' , ; ` | : . ' , ; signalConditions() ... [12:32:22.379] | : . ' , ; ` | : . ' , ; ` include = 'immediateCondition' [12:32:22.379] | : . ' , ; ` | : . ' , ; ` exclude = [12:32:22.379] | : . ' , ; ` | : . ' , ; ` resignal = FALSE [12:32:22.379] | : . ' , ; ` | : . ' , ; ` Number of conditions: 0 [12:32:22.380] | : . ' , ; ` | : . ' , ; ` int 0 [12:32:22.381] | : . ' , ; ` | : . ' , ; signalConditions() ... done [12:32:22.381] | : . ' , ; ` | : . ' , receiveMessageFromWorker() for ClusterFuture ... done [12:32:22.381] | : . ' , ; ` | : . ' , receiveMessageFromWorker() returned object of class FutureResult; resolved [12:32:22.381] | : . ' , ; ` | : . ' resolved() for ClusterFuture () ... done [12:32:22.382] | : . ' , ; ` | : . ' assertFutureResult() ... [12:32:22.382] | : . ' , ; ` | : . ' , Future uuid: 66e0468231a87fa5a50141bd001890da-1 [12:32:22.382] | : . ' , ; ` | : . ' , identical; success [12:32:22.383] | : . ' , ; ` | : . ' assertFutureResult() ... done [12:32:22.383] | : . ' , ; ` | : . resolved() ... done [12:32:22.383] | : . ' , ; ` | : . Future at position #1 is resolved ... [12:32:22.384] | : . ' , ; ` | : . ' value() for ClusterFuture () ... [12:32:22.385] | : . ' , ; ` | : . ' , result() for ClusterFuture ... [12:32:22.385] | : . ' , ; ` | : . ' , ; result already collected: FutureResult [12:32:22.385] | : . ' , ; ` | : . ' , result() for ClusterFuture ... done [12:32:22.386] | : . ' , ; ` | : . ' , result() for ClusterFuture ... [12:32:22.386] | : . ' , ; ` | : . ' , ; result already collected: FutureResult [12:32:22.386] | : . ' , ; ` | : . ' , result() for ClusterFuture ... done [12:32:22.386] | : . ' , ; ` | : . ' , signalConditions() ... [12:32:22.387] | : . ' , ; ` | : . ' , ; include = 'immediateCondition' [12:32:22.387] | : . ' , ; ` | : . ' , ; exclude = [12:32:22.387] | : . ' , ; ` | : . ' , ; resignal = FALSE [12:32:22.387] | : . ' , ; ` | : . ' , ; Number of conditions: 0 [12:32:22.388] | : . ' , ; ` | : . ' , ; int 0 [12:32:22.389] | : . ' , ; ` | : . ' , signalConditions() ... done [12:32:22.389] | : . ' , ; ` | : . ' , check for misuse ... [12:32:22.389] | : . ' , ; ` | : . ' , check for misuse ... done [12:32:22.389] | : . ' , ; ` | : . ' value() for ClusterFuture () ... done [12:32:22.390] | : . ' , ; ` | : . Future at position #1 is resolved ... done [12:32:22.390] | : . ' , ; ` | : collectValues('workers-37e5752128e4483a3ce8b7fda2d6c13d', firstOnly = TRUE) ... done [12:32:22.390] | : . ' , ; ` | : Remove collected futures ... [12:32:22.391] | : . ' , ; ` | : . Indices of futures to drop: [n=1] '1' [12:32:22.391] | : . ' , ; ` | : Remove collected futures ... done [12:32:22.391] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'collect-first', earlySignal = 1) ... done [12:32:22.391] | : . ' , ; ` | Early signaling of 1 future candidates ... [12:32:22.392] | : . ' , ; ` | Number of futures with early signaling requested: 0 [12:32:22.392] | : . ' , ; ` | Early signaling of 1 future candidates ... done [12:32:22.392] | : . ' , ; ` | Number of registered futures: 1 [12:32:22.392] | : . ' , ; ` Polling for a free worker ... done [12:32:22.393] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:22.393] | : . ' , ; ` | Listing all futures [12:32:22.393] | : . ' , ; ` | Number of registered futures: 0 [12:32:22.394] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:22.394] | : . ' , ; ` Total time: 0.118175029754639 [12:32:22.394] | : . ' , ; requestNode() ... done [12:32:22.394] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:22.395] | : . ' , ; ` Listing all futures [12:32:22.395] | : . ' , ; ` Number of registered futures: 0 [12:32:22.395] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:22.396] | : . ' , ; avail: [n=1] '1' [12:32:22.396] | : . ' , ; Index of first available worker: 1 [12:32:22.396] | : . ' , ; Validate that the worker is functional ... [12:32:22.397] | : . ' , ; ` Worker is functional [12:32:22.397] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:22.398] | : . ' , ; ` | Listing all futures [12:32:22.398] | : . ' , ; ` | Number of registered futures: 0 [12:32:22.398] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:22.398] | : . ' , ; Validate that the worker is functional ... done [12:32:22.399] | : . ' , requestWorker() ... done [12:32:22.399] | : . ' , cluster node index: 1 [12:32:22.399] | : . ' launchFuture() for ClusterFutureBackend ... done [12:32:22.400] | : . ' eraseGlobalEnvironment() ... [12:32:22.401] | : . ' eraseGlobalEnvironment() ... done [12:32:22.401] | : . ' launchFuture() ... [12:32:22.401] | : . ' , cluster node index: 1 [12:32:22.401] | : . ' , getFutureData() ... [12:32:22.402] | : . ' , ; getFutureCore() ... [12:32:22.402] | : . ' , ; ` Packages needed by the future expression (n = 0): [12:32:22.402] | : . ' , ; getFutureCore() ... done [12:32:22.403] | : . ' , ; getFutureCapture() ... [12:32:22.403] | : . ' , ; getFutureCapture() ... done [12:32:22.403] | : . ' , ; getFutureContext() ... [12:32:22.404] | : . ' , ; ` plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:22.404] | : . ' , ; ` | Getting stack without first backend: [n=0] [12:32:22.404] | : . ' , ; ` plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:22.405] | : . ' , ; ` Packages needed by future backend (n = 0): [12:32:22.405] | : . ' , ; getFutureContext() ... done [12:32:22.405] | : . ' , getFutureData() ... done [12:32:22.406] | : . ' , FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... [12:32:22.407] | : . ' , ; Appended future to position #1 [12:32:22.407] | : . ' , ; Number of registered futures: 1 [12:32:22.407] | : . ' , FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... done [12:32:22.407] | : . ' launchFuture() ... done [12:32:22.408] | : . ' ClusterFuture started [12:32:22.408] | : . Launching futures ... done [12:32:22.408] | : Using ClusterFutureBackend ... done [12:32:22.409] | : Future launched: 'ClusterFuture', 'MultiprocessFuture', 'Future' [12:32:22.409] | run() for 'Future' () ... done [12:32:22.409] future(..., label = NULL) ... done [12:32:22.411] value() for list ... [12:32:22.411] | recursive: 0 [12:32:22.412] | reduce: FALSE [12:32:22.412] | length: 2 [12:32:22.413] | Number of remaining objects: 2 [12:32:22.413] | checking value #1: [12:32:22.414] | 'obj' is ClusterFuture [12:32:22.414] | resolved() ... [12:32:22.415] | resolved() ... done [12:32:22.415] | ClusterFuture #1 [12:32:22.415] | signalConditionsASAP(ClusterFuture, pos=1) ... [12:32:22.415] | : nx: 2 [12:32:22.416] | : relay: TRUE [12:32:22.416] | : stdout: TRUE [12:32:22.416] | : signal: TRUE [12:32:22.417] | : resignal: FALSE [12:32:22.417] | : force: TRUE [12:32:22.417] | : relayed: [n=2] FALSE, FALSE [12:32:22.418] | : queued futures: [n=2] FALSE, FALSE [12:32:22.418] | : until=1 [12:32:22.418] | : relaying element #1 [12:32:22.419] | : value() for ClusterFuture () ... [12:32:22.419] | : . result() for ClusterFuture ... [12:32:22.420] | : . ' result already collected: FutureResult [12:32:22.420] | : . result() for ClusterFuture ... done [12:32:22.420] | : . result() for ClusterFuture ... [12:32:22.421] | : . ' result already collected: FutureResult [12:32:22.421] | : . result() for ClusterFuture ... done [12:32:22.421] | : . signalConditions() ... [12:32:22.422] | : . ' include = 'immediateCondition' [12:32:22.422] | : . ' exclude = [12:32:22.422] | : . ' resignal = FALSE [12:32:22.423] | : . ' Number of conditions: 0 [12:32:22.423] | : . ' int 0 [12:32:22.424] | : . signalConditions() ... done [12:32:22.424] | : . relay stdout ... [12:32:22.425] | : . relay stdout ... done [12:32:22.425] | : . check for misuse ... [12:32:22.426] | : . check for misuse ... done [12:32:22.426] | : value() for ClusterFuture () ... done [12:32:22.426] | : result() for ClusterFuture ... [12:32:22.427] | : . result already collected: FutureResult [12:32:22.427] | : result() for ClusterFuture ... done [12:32:22.427] | : signalConditions() ... [12:32:22.428] | : . include = 'immediateCondition' [12:32:22.428] | : . exclude = [12:32:22.428] | : . resignal = FALSE [12:32:22.429] | : . Number of conditions: 0 [12:32:22.429] | : . int 0 [12:32:22.430] | : signalConditions() ... done [12:32:22.430] | : result() for ClusterFuture ... [12:32:22.431] | : . result already collected: FutureResult [12:32:22.431] | : result() for ClusterFuture ... done [12:32:22.431] | : signalConditions() ... [12:32:22.432] | : . include = 'condition' [12:32:22.432] | : . exclude = 'error', 'immediateCondition' [12:32:22.432] | : . resignal = TRUE [12:32:22.433] | : . Number of conditions: 0 [12:32:22.433] | : . int 0 [12:32:22.434] | : signalConditions() ... done [12:32:22.434] | : relayed: [n=2] TRUE, FALSE [12:32:22.435] | : queued futures: [n=2] TRUE, FALSE [12:32:22.435] | signalConditionsASAP(ClusterFuture, pos=1) ... done [12:32:22.435] | value(, ...) ... [12:32:22.436] | value(, ...) ... done [12:32:22.436] | value() for ClusterFuture () ... [12:32:22.436] | : result() for ClusterFuture ... [12:32:22.437] | : . result already collected: FutureResult [12:32:22.437] | : result() for ClusterFuture ... done [12:32:22.437] | : result() for ClusterFuture ... [12:32:22.438] | : . result already collected: FutureResult [12:32:22.438] | : result() for ClusterFuture ... done [12:32:22.438] | : signalConditions() ... [12:32:22.439] | : . include = 'immediateCondition' [12:32:22.439] | : . exclude = [12:32:22.439] | : . resignal = FALSE [12:32:22.440] | : . Number of conditions: 0 [12:32:22.440] | : . int 0 [12:32:22.441] | : signalConditions() ... done [12:32:22.441] | : check for misuse ... [12:32:22.442] | : check for misuse ... done [12:32:22.442] | value() for ClusterFuture () ... done [12:32:22.442] | value: [12:32:22.443] | signalConditionsASAP(ClusterFuture, pos=1) ... [12:32:22.443] | : nx: 2 [12:32:22.443] | : relay: TRUE [12:32:22.444] | : stdout: TRUE [12:32:22.444] | : signal: TRUE [12:32:22.444] | : resignal: FALSE [12:32:22.445] | : force: TRUE [12:32:22.445] | : relayed: [n=2] TRUE, FALSE [12:32:22.445] | : queued futures: [n=2] TRUE, FALSE [12:32:22.446] | : until=2 [12:32:22.446] | : relaying element #2 [12:32:22.446] | : relayed: [n=2] TRUE, FALSE [12:32:22.446] | : queued futures: [n=2] TRUE, FALSE [12:32:22.447] | signalConditionsASAP(ClusterFuture, pos=1) ... done [12:32:22.447] | resolve() for ClusterFuture ... [12:32:22.448] | resolve() for ClusterFuture ... done [12:32:22.448] | length: 1 (resolved future 1) [12:32:22.448] value() for list ... done [12:32:22.449] checking value #2: [12:32:22.449] 'obj' is ClusterFuture [12:32:22.449] resolved() ... [12:32:22.450] | resolved() for ClusterFuture () ... [12:32:22.450] | : Cluster node socket connection: index=4, id=139 [12:32:22.451] | : assertValidConnection() ... [12:32:22.451] | : . cluster node index: 1 [12:32:22.452] | : assertValidConnection() ... done [12:32:22.452] | : receiveMessageFromWorker() for ClusterFuture ... [12:32:22.453] | : . cluster node index: 1 [12:32:22.453] | : . [1] TRUE [12:32:22.454] | : . Received data: [12:32:22.454] | : . List of 5 [12:32:22.454] | : . $ type : chr "VALUE" [12:32:22.454] | : . $ value :List of 16 [12:32:22.454] | : . ..$ value : int 2 [12:32:22.454] | : . ..$ visible : logi TRUE [12:32:22.454] | : . ..$ stdout : chr "" [12:32:22.454] | : . ..$ conditions : list() [12:32:22.454] | : . ..$ rng : logi FALSE [12:32:22.454] | : . ..$ seed : NULL [12:32:22.454] | : . ..$ misuseGlobalEnv : NULL [12:32:22.454] | : . ..$ misuseConnections :List of 3 [12:32:22.454] | : . .. ..$ added : NULL [12:32:22.454] | : . .. ..$ removed : NULL [12:32:22.454] | : . .. ..$ replaced: NULL [12:32:22.454] | : . ..$ misuseDevices : NULL [12:32:22.454] | : . ..$ misuseDefaultDevice: list() [12:32:22.454] | : . ..$ started : POSIXct[1:1], format: "2025-07-29 12:32:22" [12:32:22.454] | : . ..$ finished : POSIXct[1:1], format: "2025-07-29 12:32:22" [12:32:22.454] | : . ..$ uuid : chr [1:2] "66e0468231a87fa5a50141bd001890da" "2" [12:32:22.454] | : . ..$ session_uuid : chr "90b0ad0ad06d76740e72e872181f8708" [12:32:22.454] | : . .. ..- attr(*, "source")=List of 5 [12:32:22.454] | : . .. .. ..$ host : Named chr "CRANWIN3" [12:32:22.454] | : . .. .. .. ..- attr(*, "names")= chr "COMPUTERNAME" [12:32:22.454] | : . .. .. ..$ info : Named chr [1:9] "Windows" "Server x64" "build 20348" "CRANWIN3" ... [12:32:22.454] | : . .. .. .. ..- attr(*, "names")= chr [1:9] "sysname" "release" "version" "nodename" ... [12:32:22.454] | : . .. .. ..$ pid : int 104460 [12:32:22.454] | : . .. .. ..$ time : POSIXct[1:1], format: "2025-07-29 12:32:22" [12:32:22.454] | : . .. .. ..$ random: int 2147483647 [12:32:22.454] | : . ..$ r_info :List of 4 [12:32:22.454] | : . .. ..$ version :Classes 'R_system_version', 'package_version', 'numeric_version' hidden list of 1 [12:32:22.454] | : . .. .. ..$ : int [1:3] 4 6 0 [12:32:22.454] | : . .. ..$ os : chr "windows" [12:32:22.454] | : . .. ..$ os_name : chr "Windows" [12:32:22.454] | : . .. ..$ captures_utf8: logi TRUE [12:32:22.454] | : . ..$ version : chr "1.8" [12:32:22.454] | : . ..- attr(*, "class")= chr "FutureResult" [12:32:22.454] | : . $ success: logi TRUE [12:32:22.454] | : . $ time : 'proc_time' Named num [1:5] 0.01 0 0.01 NA NA [12:32:22.454] | : . ..- attr(*, "names")= chr [1:5] "user.self" "sys.self" "elapsed" "user.child" ... [12:32:22.454] | : . $ tag : NULL [12:32:22.480] | : . Received FutureResult [12:32:22.480] | : . FutureResult: [12:32:22.480] | : . value: 'integer' [12:32:22.480] | : . visible: TRUE [12:32:22.480] | : . stdout: character [12:32:22.480] | : . conditions: [n = 0] [12:32:22.480] | : . RNG used: FALSE [12:32:22.480] | : . duration: 0.005861998 secs (started 2025-07-29 12:32:22.407079) [12:32:22.480] | : . version: 1.8 [12:32:22.481] | : . FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... [12:32:22.481] | : . ' Removed future from position #1 [12:32:22.481] | : . ' Number of registered futures: 0 [12:32:22.482] | : . FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... done [12:32:22.482] | : . Erased future from future backend [12:32:22.482] | : . result() for ClusterFuture ... [12:32:22.482] | : . ' result already collected: FutureResult [12:32:22.482] | : . result() for ClusterFuture ... done [12:32:22.483] | : . signalConditions() ... [12:32:22.483] | : . ' include = 'immediateCondition' [12:32:22.483] | : . ' exclude = [12:32:22.483] | : . ' resignal = FALSE [12:32:22.483] | : . ' Number of conditions: 0 [12:32:22.484] | : . ' int 0 [12:32:22.484] | : . signalConditions() ... done [12:32:22.484] | : receiveMessageFromWorker() for ClusterFuture ... done [12:32:22.485] | : receiveMessageFromWorker() returned object of class FutureResult; resolved [12:32:22.485] | resolved() for ClusterFuture () ... done [12:32:22.485] | assertFutureResult() ... [12:32:22.485] | : Future uuid: 66e0468231a87fa5a50141bd001890da-2 [12:32:22.485] | : identical; success [12:32:22.486] | assertFutureResult() ... done [12:32:22.486] resolved() ... done [12:32:22.486] ClusterFuture #2 [12:32:22.486] signalConditionsASAP(ClusterFuture, pos=2) ... [12:32:22.486] | nx: 2 [12:32:22.487] | relay: TRUE [12:32:22.487] | stdout: TRUE [12:32:22.487] | signal: TRUE [12:32:22.487] | resignal: FALSE [12:32:22.487] | force: TRUE [12:32:22.488] | relayed: [n=2] TRUE, FALSE [12:32:22.488] | queued futures: [n=2] TRUE, FALSE [12:32:22.488] | until=2 [12:32:22.489] | relaying element #2 [12:32:22.489] | value() for ClusterFuture () ... [12:32:22.489] | : result() for ClusterFuture ... [12:32:22.490] | : . result already collected: FutureResult [12:32:22.490] | : result() for ClusterFuture ... done [12:32:22.490] | : result() for ClusterFuture ... [12:32:22.491] | : . result already collected: FutureResult [12:32:22.491] | : result() for ClusterFuture ... done [12:32:22.491] | : signalConditions() ... [12:32:22.491] | : . include = 'immediateCondition' [12:32:22.491] | : . exclude = [12:32:22.492] | : . resignal = FALSE [12:32:22.492] | : . Number of conditions: 0 [12:32:22.492] | : . int 0 [12:32:22.493] | : signalConditions() ... done [12:32:22.493] | : relay stdout ... [12:32:22.493] | : relay stdout ... done [12:32:22.493] | : check for misuse ... [12:32:22.494] | : check for misuse ... done [12:32:22.494] | value() for ClusterFuture () ... done [12:32:22.495] | result() for ClusterFuture ... [12:32:22.495] | : result already collected: FutureResult [12:32:22.495] | result() for ClusterFuture ... done [12:32:22.495] | signalConditions() ... [12:32:22.496] | : include = 'immediateCondition' [12:32:22.496] | : exclude = [12:32:22.496] | : resignal = FALSE [12:32:22.497] | : Number of conditions: 0 [12:32:22.497] | : int 0 [12:32:22.498] | signalConditions() ... done [12:32:22.498] | result() for ClusterFuture ... [12:32:22.498] | : result already collected: FutureResult [12:32:22.498] | result() for ClusterFuture ... done [12:32:22.499] | signalConditions() ... [12:32:22.499] | : include = 'condition' [12:32:22.499] | : exclude = 'error', 'immediateCondition' [12:32:22.499] | : resignal = TRUE [12:32:22.499] | : Number of conditions: 0 [12:32:22.500] | : int 0 [12:32:22.500] | signalConditions() ... done [12:32:22.500] | relayed: [n=2] TRUE, TRUE [12:32:22.501] | queued futures: [n=2] TRUE, TRUE [12:32:22.501] signalConditionsASAP(ClusterFuture, pos=2) ... done [12:32:22.501] value(, ...) ... [12:32:22.502] value(, ...) ... done [12:32:22.502] value() for ClusterFuture () ... [12:32:22.502] | result() for ClusterFuture ... [12:32:22.503] | : result already collected: FutureResult [12:32:22.503] | result() for ClusterFuture ... done [12:32:22.503] | result() for ClusterFuture ... [12:32:22.504] | : result already collected: FutureResult [12:32:22.504] | result() for ClusterFuture ... done [12:32:22.504] | signalConditions() ... [12:32:22.504] | : include = 'immediateCondition' [12:32:22.505] | : exclude = [12:32:22.505] | : resignal = FALSE [12:32:22.505] | : Number of conditions: 0 [12:32:22.506] | : int 0 [12:32:22.507] | signalConditions() ... done [12:32:22.507] | check for misuse ... [12:32:22.507] | check for misuse ... done [12:32:22.508] value() for ClusterFuture () ... done [12:32:22.508] value: [12:32:22.508] signalConditionsASAP(ClusterFuture, pos=2) ... [12:32:22.509] | nx: 2 [12:32:22.509] | relay: TRUE [12:32:22.509] | stdout: TRUE [12:32:22.510] | signal: TRUE [12:32:22.510] | resignal: FALSE [12:32:22.510] | force: TRUE [12:32:22.510] | relayed: [n=2] TRUE, TRUE [12:32:22.511] | queued futures: [n=2] TRUE, TRUE [12:32:22.511] | until=2 [12:32:22.511] | relayed: [n=2] TRUE, TRUE [12:32:22.512] | queued futures: [n=2] TRUE, TRUE [12:32:22.512] signalConditionsASAP(ClusterFuture, pos=2) ... done [12:32:22.512] resolve() for ClusterFuture ... [12:32:22.513] resolve() for ClusterFuture ... done [12:32:22.513] length: 0 (resolved future 2) [12:32:22.514] Relaying remaining futures ... [12:32:22.514] | signalConditionsASAP(NULL, pos=0) ... [12:32:22.514] | : nx: 2 [12:32:22.515] | : relay: TRUE [12:32:22.515] | : stdout: TRUE [12:32:22.515] | : signal: TRUE [12:32:22.516] | : resignal: FALSE [12:32:22.516] | : force: TRUE [12:32:22.516] | : relayed: [n=2] TRUE, TRUE [12:32:22.517] | : queued futures: [n=2] TRUE, TRUE - flush all [12:32:22.517] | : relayed: [n=2] TRUE, TRUE [12:32:22.517] | : queued futures: [n=2] TRUE, TRUE [12:32:22.518] | signalConditionsASAP(NULL, pos=0) ... done [12:32:22.518] Relaying remaining futures ... done Iteration #2 [12:32:22.788] plan(<'name'>, .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:22.789] | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = NA, init = TRUE) ... [12:32:22.789] | : all.equal() for FutureStrategyList ... [12:32:22.790] | : . New stack: [12:32:22.790] | : . List of 1 [12:32:22.790] | : . $ :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:22.790] | : . ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:22.790] | : . ..- attr(*, "init")= logi TRUE [12:32:22.790] | : . ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:22.790] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:22.790] | : . .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.790] | : . ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.790] | : . ..- attr(*, "tweaks")=List of 1 [12:32:22.790] | : . .. ..$ workers:List of 1 [12:32:22.790] | : . .. .. ..$ :List of 3 [12:32:22.790] | : . .. .. .. ..$ con : 'sockconn' int 4 [12:32:22.790] | : . .. .. .. .. ..- attr(*, "conn_id")= [12:32:22.790] | : . .. .. .. ..$ host: chr "localhost" [12:32:22.790] | : . .. .. .. ..$ rank: num 0 [12:32:22.790] | : . .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:22.790] | : . .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:22.790] | : . ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:22.790] | : . - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:22.805] | : . Old stack: [12:32:22.805] | : . List of 1 [12:32:22.805] | : . $ :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:22.805] | : . ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:22.805] | : . ..- attr(*, "init")= chr "done" [12:32:22.805] | : . ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:22.805] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:22.805] | : . .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.805] | : . ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.805] | : . ..- attr(*, "tweaks")=List of 1 [12:32:22.805] | : . .. ..$ workers:List of 1 [12:32:22.805] | : . .. .. ..$ :List of 3 [12:32:22.805] | : . .. .. .. ..$ con : 'sockconn' int 4 [12:32:22.805] | : . .. .. .. .. ..- attr(*, "conn_id")= [12:32:22.805] | : . .. .. .. ..$ host: chr "localhost" [12:32:22.805] | : . .. .. .. ..$ rank: num 0 [12:32:22.805] | : . .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:22.805] | : . .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:22.805] | : . ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:22.805] | : . ..- attr(*, "backend")=Classes 'ClusterFutureBackend', 'MultiprocessFutureBackend', 'FutureBackend', 'environment' [12:32:22.805] | : . .. ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:22.805] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:22.805] | : . .. .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.805] | : . - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:22.821] | : . Not identical [12:32:22.822] | : . all.equal() for future ... [12:32:22.822] | : . ' List of 2 [12:32:22.822] | : . ' $ target :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:22.822] | : . ' ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:22.822] | : . ' ..- attr(*, "init")= logi TRUE [12:32:22.822] | : . ' ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:22.822] | : . ' earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:22.822] | : . ' .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.822] | : . ' ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.822] | : . ' ..- attr(*, "tweaks")=List of 1 [12:32:22.822] | : . ' .. ..$ workers:List of 1 [12:32:22.822] | : . ' .. .. ..$ :List of 3 [12:32:22.822] | : . ' .. .. .. ..$ con : 'sockconn' int 4 [12:32:22.822] | : . ' .. .. .. .. ..- attr(*, "conn_id")= [12:32:22.822] | : . ' .. .. .. ..$ host: chr "localhost" [12:32:22.822] | : . ' .. .. .. ..$ rank: num 0 [12:32:22.822] | : . ' .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:22.822] | : . ' .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:22.822] | : . ' ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:22.822] | : . ' $ current:function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:22.822] | : . ' ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:22.822] | : . ' ..- attr(*, "init")= chr "done" [12:32:22.822] | : . ' ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:22.822] | : . ' earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:22.822] | : . ' .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.822] | : . ' ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.822] | : . ' ..- attr(*, "tweaks")=List of 1 [12:32:22.822] | : . ' .. ..$ workers:List of 1 [12:32:22.822] | : . ' .. .. ..$ :List of 3 [12:32:22.822] | : . ' .. .. .. ..$ con : 'sockconn' int 4 [12:32:22.822] | : . ' .. .. .. .. ..- attr(*, "conn_id")= [12:32:22.822] | : . ' .. .. .. ..$ host: chr "localhost" [12:32:22.822] | : . ' .. .. .. ..$ rank: num 0 [12:32:22.822] | : . ' .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:22.822] | : . ' .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:22.822] | : . ' ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:22.822] | : . ' ..- attr(*, "backend")=Classes 'ClusterFutureBackend', 'MultiprocessFutureBackend', 'FutureBackend', 'environment' [12:32:22.822] | : . ' .. ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:22.822] | : . ' earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:22.822] | : . ' .. .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.850] | : . ' Formals differ [12:32:22.850] | : . all.equal() for future ... done [12:32:22.851] | : . Future strategies differ at level 1 [12:32:22.851] | : all.equal() for FutureStrategyList ... done [12:32:22.851] | : plan(): Setting new future backend stack: [12:32:22.852] | : List of future strategies: [12:32:22.852] | : 1. cluster: [12:32:22.852] | : - args: function (..., workers = "") [12:32:22.852] | : - tweaked: TRUE [12:32:22.852] | : - call: plan(cluster, workers = cl) [12:32:22.853] | : List of 1 [12:32:22.853] | : $ :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:22.853] | : ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:22.853] | : ..- attr(*, "init")= logi TRUE [12:32:22.853] | : ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:22.853] | : earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:22.853] | : .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.853] | : ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.853] | : ..- attr(*, "tweaks")=List of 1 [12:32:22.853] | : .. ..$ workers:List of 1 [12:32:22.853] | : .. .. ..$ :List of 3 [12:32:22.853] | : .. .. .. ..$ con : 'sockconn' int 4 [12:32:22.853] | : .. .. .. .. ..- attr(*, "conn_id")= [12:32:22.853] | : .. .. .. ..$ host: chr "localhost" [12:32:22.853] | : .. .. .. ..$ rank: num 0 [12:32:22.853] | : .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:22.853] | : .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:22.853] | : ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:22.853] | : - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:22.865] | : plan(): plan_cleanup(<'tweaked', 'cluster', 'multiprocess', 'future', 'function'>, cleanup = NA) ... [12:32:22.865] | : . plan("next", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:22.866] | : . ' Getting current ("next") strategy: 'FutureStrategy', 'tweaked', 'cluster', 'multiprocess', 'future', 'function' [12:32:22.866] | : . plan("next", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:22.866] | : . stopWorkers() for ClusterFutureBackend ... [12:32:22.867] | : . ' Interrupt active futures ... [12:32:22.868] | : . ' , Number of futures: 0 [12:32:22.869] | : . ' Interrupt active futures ... done [12:32:22.869] | : . ' Clear future registry ... [12:32:22.870] | : . ' Clear future registry ... done [12:32:22.870] | : . ' Stop cluster workers ... [12:32:22.871] | : . ' , Stopping existing cluster ... [12:32:22.871] | : . ' , ; No pre-existing cluster. Skipping [12:32:22.871] | : . ' , Stopping existing cluster ... done [12:32:22.872] | : . ' Stop cluster workers ... done [12:32:22.872] | : . stopWorkers() for ClusterFutureBackend ... done [12:32:22.873] | : . Legacy shutdown of cluster workers ... [12:32:22.873] | : . ' Stopping existing cluster ... [12:32:22.873] | : . ' , No pre-existing cluster. Skipping [12:32:22.873] | : . ' Stopping existing cluster ... done [12:32:22.874] | : . Legacy shutdown of cluster workers ... done [12:32:22.874] | : plan(): plan_cleanup(<'tweaked', 'cluster', 'multiprocess', 'future', 'function'>, cleanup = NA) ... done [12:32:22.875] | : plan(): plan_init() of 'tweaked', 'cluster', 'multiprocess', 'future', 'function' ... [12:32:22.875] | : . function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:22.875] | : . - attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:22.875] | : . - attr(*, "init")= logi TRUE [12:32:22.875] | : . - attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:22.875] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:22.875] | : . ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.875] | : . - attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:22.875] | : . - attr(*, "tweaks")=List of 1 [12:32:22.875] | : . ..$ workers:List of 1 [12:32:22.875] | : . .. ..$ :List of 3 [12:32:22.875] | : . .. .. ..$ con : 'sockconn' int 4 [12:32:22.875] | : . .. .. .. ..- attr(*, "conn_id")= [12:32:22.875] | : . .. .. ..$ host: chr "localhost" [12:32:22.875] | : . .. .. ..$ rank: num 0 [12:32:22.875] | : . .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:22.875] | : . .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:22.875] | : . - attr(*, "call")= language plan(cluster, workers = cl) [12:32:22.886] | : . init: TRUE [12:32:22.886] | : . makeFutureBackend() ... [12:32:22.886] | : . ' Backend function: <'NULL'> [12:32:22.887] | : . ' Evaluator tweak arguments: [n=1] [12:32:22.887] | : . ' List of 1 [12:32:22.887] | : . ' $ workers:List of 1 [12:32:22.887] | : . ' ..$ :List of 3 [12:32:22.887] | : . ' .. ..$ con : 'sockconn' int 4 [12:32:22.887] | : . ' .. .. ..- attr(*, "conn_id")= [12:32:22.887] | : . ' .. ..$ host: chr "localhost" [12:32:22.887] | : . ' .. ..$ rank: num 0 [12:32:22.887] | : . ' .. ..- attr(*, "class")= chr "SOCKnode" [12:32:22.887] | : . ' ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:22.893] | : . ' Evaluator formal arguments: [n=1] [12:32:22.893] | : . ' List of 1 [12:32:22.893] | : . ' $ workers:List of 1 [12:32:22.893] | : . ' ..$ :List of 3 [12:32:22.893] | : . ' .. ..$ con : 'sockconn' int 4 [12:32:22.893] | : . ' .. .. ..- attr(*, "conn_id")= [12:32:22.893] | : . ' .. ..$ host: chr "localhost" [12:32:22.893] | : . ' .. ..$ rank: num 0 [12:32:22.893] | : . ' .. ..- attr(*, "class")= chr "SOCKnode" [12:32:22.893] | : . ' ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:22.899] | : . ' Backend factory arguments: [n=1] [12:32:22.900] | : . ' Dotted pair list of 1 [12:32:22.900] | : . ' $ workers:List of 1 [12:32:22.900] | : . ' ..$ :List of 3 [12:32:22.900] | : . ' .. ..$ con : 'sockconn' int 4 [12:32:22.900] | : . ' .. .. ..- attr(*, "conn_id")= [12:32:22.900] | : . ' .. ..$ host: chr "localhost" [12:32:22.900] | : . ' .. ..$ rank: num 0 [12:32:22.900] | : . ' .. ..- attr(*, "class")= chr "SOCKnode" [12:32:22.900] | : . ' ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:22.952] | : . ' ClusterFutureBackend(..., persistent = FALSE, gc = TRUE, earlySignal = TRUE) ... [12:32:22.952] | : . ' , Stopping existing cluster ... [12:32:22.952] | : . ' , ; No pre-existing cluster. Skipping [12:32:22.953] | : . ' , Stopping existing cluster ... done [12:32:22.953] | : . ' , Number of workers: 1 [12:32:22.953] | : . ' , Generated workers UUID [12:32:22.953] | : . ' , Workers UUID: '37e5752128e4483a3ce8b7fda2d6c13d' [12:32:22.954] | : . ' ClusterFutureBackend(..., persistent = FALSE, gc = TRUE, earlySignal = TRUE) ... done [12:32:22.954] | : . ' Backend: <'ClusterFutureBackend', 'MultiprocessFutureBackend', 'FutureBackend', 'environment'> [12:32:22.954] | : . makeFutureBackend() ... done [12:32:22.954] | : plan(): plan_init() of 'tweaked', 'cluster', 'multiprocess', 'future', 'function' ... done [12:32:22.955] | : nbrOfWorkers(NULL) ... [12:32:22.955] | : . List of 4 [12:32:22.955] | : . $ : language plan_set(newStack, skip = .skip, cleanup = .cleanup, init = .init, debug = debug) [12:32:22.955] | : . $ : language with_assert({ nbrOfWorkers <- nbrOfWorkers() ... [12:32:22.955] | : . $ : language nbrOfWorkers() [12:32:22.955] | : . $ : language nbrOfWorkers.NULL() [12:32:22.958] | : . plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:22.958] | : . plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:22.958] | : . Number of workers: 1 [12:32:22.958] | : nbrOfWorkers(NULL) ... done [12:32:22.959] | : plan(): nbrOfWorkers() = 1 [12:32:22.959] | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = NA, init = TRUE) ... done [12:32:22.959] plan(<'name'>, .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:22.959] future(..., label = NULL) ... [12:32:22.960] | lazy: FALSE [12:32:22.960] | stdout: TRUE [12:32:22.960] | conditions: [n=1] 'condition' [12:32:22.960] | gc: FALSE [12:32:22.960] | earlySignal: FALSE [12:32:22.960] | getGlobalsAndPackages() ... [12:32:22.961] | : Searching for globals ... [12:32:22.966] | : . globals found: [3] '[[', 'X', 'i' [12:32:22.966] | : Searching for globals ... done [12:32:22.967] | : Resolving globals: FALSE [12:32:22.967] | : Search for packages associated with the globals ... [12:32:22.967] | : . Packages associated with globals: [1] 'base' [12:32:22.968] | : . Packages: [1] 'base' [12:32:22.968] | : Search for packages associated with the globals ... done [12:32:22.971] | : Packages after dropping 'base': [0] [12:32:22.971] | : globals: [2] 'X', 'i' [12:32:22.971] | : packages: [0] [12:32:22.972] | getGlobalsAndPackages() ... done [12:32:22.972] | run() for 'Future' () ... [12:32:22.972] | : state: 'created' [12:32:22.972] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:22.972] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:22.973] | : Using ClusterFutureBackend ... [12:32:22.973] | : . Number of futures since start: 0 (0 created, 0 launched, 0 finished) [12:32:22.973] | : . Launching futures ... [12:32:22.973] | : . ' launchFuture() for ClusterFutureBackend ... [12:32:22.973] | : . ' , Workers: [n=1] [12:32:22.974] | : . ' , socket cluster with 1 nodes on host 'localhost' [12:32:22.974] | : . ' , FutureRegistry: 'workers-37e5752128e4483a3ce8b7fda2d6c13d' [12:32:22.974] | : . ' , requestWorker() ... [12:32:22.974] | : . ' , ; requestNode() ... [12:32:22.974] | : . ' , ; ` Number of workers: 1 [12:32:22.975] | : . ' , ; ` Polling for a free worker ... [12:32:22.975] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:22.975] | : . ' , ; ` | : Listing all futures [12:32:22.975] | : . ' , ; ` | : Number of registered futures: 0 [12:32:22.975] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:22.975] | : . ' , ; ` | Total time: 0 [12:32:22.976] | : . ' , ; ` Polling for a free worker ... done [12:32:22.976] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:22.976] | : . ' , ; ` | Listing all futures [12:32:22.976] | : . ' , ; ` | Number of registered futures: 0 [12:32:22.976] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:22.976] | : . ' , ; ` avail: [n=1] '1' [12:32:22.977] | : . ' , ; ` Index of first available worker: 1 [12:32:22.977] | : . ' , ; ` Validate that the worker is functional ... [12:32:22.978] | : . ' , ; ` | Worker is functional [12:32:22.978] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:22.978] | : . ' , ; ` | : Listing all futures [12:32:22.978] | : . ' , ; ` | : Number of registered futures: 0 [12:32:22.978] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:22.978] | : . ' , ; ` Validate that the worker is functional ... done [12:32:22.979] | : . ' , ; requestNode() ... done [12:32:22.979] | : . ' , ; cluster node index: 1 [12:32:22.979] | : . ' , requestWorker() ... done [12:32:22.979] | : . ' , eraseGlobalEnvironment() ... [12:32:23.109] | : . ' , eraseGlobalEnvironment() ... done [12:32:23.109] | : . ' , launchFuture() ... [12:32:23.109] | : . ' , ; cluster node index: 1 [12:32:23.110] | : . ' , ; getFutureData() ... [12:32:23.110] | : . ' , ; ` getFutureCore() ... [12:32:23.110] | : . ' , ; ` | Packages needed by the future expression (n = 0): [12:32:23.111] | : . ' , ; ` getFutureCore() ... done [12:32:23.111] | : . ' , ; ` getFutureCapture() ... [12:32:23.111] | : . ' , ; ` getFutureCapture() ... done [12:32:23.112] | : . ' , ; ` getFutureContext() ... [12:32:23.112] | : . ' , ; ` | plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:23.112] | : . ' , ; ` | : Getting stack without first backend: [n=0] [12:32:23.113] | : . ' , ; ` | plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:23.113] | : . ' , ; ` | Packages needed by future backend (n = 0): [12:32:23.113] | : . ' , ; ` getFutureContext() ... done [12:32:23.114] | : . ' , ; getFutureData() ... done [12:32:23.115] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... [12:32:23.115] | : . ' , ; ` Appended future to position #1 [12:32:23.116] | : . ' , ; ` Number of registered futures: 1 [12:32:23.116] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... done [12:32:23.116] | : . ' , launchFuture() ... done [12:32:23.116] | : . ' , ClusterFuture started [12:32:23.117] | : . ' launchFuture() for ClusterFutureBackend ... done [12:32:23.117] | : . Launching futures ... done [12:32:23.117] | : . Future launched: 'ClusterFuture', 'MultiprocessFuture', 'Future' [12:32:23.118] | : Using ClusterFutureBackend ... done [12:32:23.118] | run() for 'Future' () ... done [12:32:23.118] future(..., label = NULL) ... done [12:32:23.119] future(..., label = NULL) ... [12:32:23.119] | lazy: FALSE [12:32:23.119] | stdout: TRUE [12:32:23.120] | conditions: [n=1] 'condition' [12:32:23.120] | gc: FALSE [12:32:23.120] | earlySignal: FALSE [12:32:23.121] | getGlobalsAndPackages() ... [12:32:23.121] | : Searching for globals ... [12:32:23.131] | : . globals found: [3] '[[', 'X', 'i' [12:32:23.131] | : Searching for globals ... done [12:32:23.132] | : Resolving globals: FALSE [12:32:23.132] | : Search for packages associated with the globals ... [12:32:23.133] | : . Packages associated with globals: [1] 'base' [12:32:23.133] | : . Packages: [1] 'base' [12:32:23.134] | : Search for packages associated with the globals ... done [12:32:23.134] | : Packages after dropping 'base': [0] [12:32:23.134] | : globals: [2] 'X', 'i' [12:32:23.135] | : packages: [0] [12:32:23.135] | getGlobalsAndPackages() ... done [12:32:23.136] | run() for 'Future' () ... [12:32:23.136] | : state: 'created' [12:32:23.136] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:23.137] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:23.137] | : Using ClusterFutureBackend ... [12:32:23.137] | : . Number of futures since start: 1 (1 created, 1 launched, 0 finished) [12:32:23.138] | : . Launching futures ... [12:32:23.138] | : . ' launchFuture() for ClusterFutureBackend ... [12:32:23.138] | : . ' , Workers: [n=1] [12:32:23.139] | : . ' , socket cluster with 1 nodes on host 'localhost' [12:32:23.139] | : . ' , FutureRegistry: 'workers-37e5752128e4483a3ce8b7fda2d6c13d' [12:32:23.140] | : . ' , requestWorker() ... [12:32:23.140] | : . ' , ; requestNode() ... [12:32:23.140] | : . ' , ; ` Number of workers: 1 [12:32:23.141] | : . ' , ; ` Polling for a free worker ... [12:32:23.141] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:23.141] | : . ' , ; ` | : Listing all futures [12:32:23.142] | : . ' , ; ` | : Number of registered futures: 1 [12:32:23.142] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:23.142] | : . ' , ; ` | Poll #1 (0): usedNodes() = 1, workers = 1 [12:32:23.159] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'collect-first', earlySignal = 1) ... [12:32:23.216] | : . ' , ; ` | : collectValues('workers-37e5752128e4483a3ce8b7fda2d6c13d', firstOnly = TRUE) ... [12:32:23.217] | : . ' , ; ` | : . resolved() ... [12:32:23.217] | : . ' , ; ` | : . ' resolved() for ClusterFuture () ... [12:32:23.218] | : . ' , ; ` | : . ' , Cluster node socket connection: index=4, id=180 [12:32:23.218] | : . ' , ; ` | : . ' , assertValidConnection() ... [12:32:23.218] | : . ' , ; ` | : . ' , ; cluster node index: 1 [12:32:23.219] | : . ' , ; ` | : . ' , assertValidConnection() ... done [12:32:23.219] | : . ' , ; ` | : . ' , receiveMessageFromWorker() for ClusterFuture ... [12:32:23.220] | : . ' , ; ` | : . ' , ; cluster node index: 1 [12:32:23.220] | : . ' , ; ` | : . ' , ; [1] TRUE [12:32:23.221] | : . ' , ; ` | : . ' , ; Received data: [12:32:23.221] | : . ' , ; ` | : . ' , ; List of 5 [12:32:23.221] | : . ' , ; ` | : . ' , ; $ type : chr "VALUE" [12:32:23.221] | : . ' , ; ` | : . ' , ; $ value :List of 16 [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ value : int 1 [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ visible : logi TRUE [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ stdout : chr "" [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ conditions : list() [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ rng : logi FALSE [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ seed : NULL [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ misuseGlobalEnv : NULL [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ misuseConnections :List of 3 [12:32:23.221] | : . ' , ; ` | : . ' , ; .. ..$ added : NULL [12:32:23.221] | : . ' , ; ` | : . ' , ; .. ..$ removed : NULL [12:32:23.221] | : . ' , ; ` | : . ' , ; .. ..$ replaced: NULL [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ misuseDevices : NULL [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ misuseDefaultDevice: list() [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ started : POSIXct[1:1], format: "2025-07-29 12:32:23" [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ finished : POSIXct[1:1], format: "2025-07-29 12:32:23" [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ uuid : chr [1:2] "66e0468231a87fa5a50141bd001890da" "3" [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ session_uuid : chr "0e543e37a923b5a7603525f78e8264b1" [12:32:23.221] | : . ' , ; ` | : . ' , ; .. ..- attr(*, "source")=List of 5 [12:32:23.221] | : . ' , ; ` | : . ' , ; .. .. ..$ host : Named chr "CRANWIN3" [12:32:23.221] | : . ' , ; ` | : . ' , ; .. .. .. ..- attr(*, "names")= chr "COMPUTERNAME" [12:32:23.221] | : . ' , ; ` | : . ' , ; .. .. ..$ info : Named chr [1:9] "Windows" "Server x64" "build 20348" "CRANWIN3" ... [12:32:23.221] | : . ' , ; ` | : . ' , ; .. .. .. ..- attr(*, "names")= chr [1:9] "sysname" "release" "version" "nodename" ... [12:32:23.221] | : . ' , ; ` | : . ' , ; .. .. ..$ pid : int 150644 [12:32:23.221] | : . ' , ; ` | : . ' , ; .. .. ..$ time : POSIXct[1:1], format: "2025-07-29 12:32:23" [12:32:23.221] | : . ' , ; ` | : . ' , ; .. .. ..$ random: int 2147483647 [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ r_info :List of 4 [12:32:23.221] | : . ' , ; ` | : . ' , ; .. ..$ version :Classes 'R_system_version', 'package_version', 'numeric_version' hidden list of 1 [12:32:23.221] | : . ' , ; ` | : . ' , ; .. .. ..$ : int [1:3] 4 6 0 [12:32:23.221] | : . ' , ; ` | : . ' , ; .. ..$ os : chr "windows" [12:32:23.221] | : . ' , ; ` | : . ' , ; .. ..$ os_name : chr "Windows" [12:32:23.221] | : . ' , ; ` | : . ' , ; .. ..$ captures_utf8: logi TRUE [12:32:23.221] | : . ' , ; ` | : . ' , ; ..$ version : chr "1.8" [12:32:23.221] | : . ' , ; ` | : . ' , ; ..- attr(*, "class")= chr "FutureResult" [12:32:23.221] | : . ' , ; ` | : . ' , ; $ success: logi TRUE [12:32:23.221] | : . ' , ; ` | : . ' , ; $ time : 'proc_time' Named num [1:5] 0.08 0 0.08 NA NA [12:32:23.221] | : . ' , ; ` | : . ' , ; ..- attr(*, "names")= chr [1:5] "user.self" "sys.self" "elapsed" "user.child" ... [12:32:23.221] | : . ' , ; ` | : . ' , ; $ tag : NULL [12:32:23.246] | : . ' , ; ` | : . ' , ; Received FutureResult [12:32:23.246] | : . ' , ; ` | : . ' , ; FutureResult: [12:32:23.246] | : . ' , ; ` | : . ' , ; value: 'integer' [12:32:23.246] | : . ' , ; ` | : . ' , ; visible: TRUE [12:32:23.246] | : . ' , ; ` | : . ' , ; stdout: character [12:32:23.246] | : . ' , ; ` | : . ' , ; conditions: [n = 0] [12:32:23.246] | : . ' , ; ` | : . ' , ; RNG used: FALSE [12:32:23.246] | : . ' , ; ` | : . ' , ; duration: 0.08432794 secs (started 2025-07-29 12:32:23.117211) [12:32:23.246] | : . ' , ; ` | : . ' , ; version: 1.8 [12:32:23.247] | : . ' , ; ` | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... [12:32:23.248] | : . ' , ; ` | : . ' , ; ` Removed future from position #1 [12:32:23.248] | : . ' , ; ` | : . ' , ; ` Number of registered futures: 0 [12:32:23.248] | : . ' , ; ` | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... done [12:32:23.249] | : . ' , ; ` | : . ' , ; Erased future from future backend [12:32:23.249] | : . ' , ; ` | : . ' , ; result() for ClusterFuture ... [12:32:23.249] | : . ' , ; ` | : . ' , ; ` result already collected: FutureResult [12:32:23.249] | : . ' , ; ` | : . ' , ; result() for ClusterFuture ... done [12:32:23.250] | : . ' , ; ` | : . ' , ; signalConditions() ... [12:32:23.250] | : . ' , ; ` | : . ' , ; ` include = 'immediateCondition' [12:32:23.250] | : . ' , ; ` | : . ' , ; ` exclude = [12:32:23.251] | : . ' , ; ` | : . ' , ; ` resignal = FALSE [12:32:23.251] | : . ' , ; ` | : . ' , ; ` Number of conditions: 0 [12:32:23.251] | : . ' , ; ` | : . ' , ; ` int 0 [12:32:23.252] | : . ' , ; ` | : . ' , ; signalConditions() ... done [12:32:23.252] | : . ' , ; ` | : . ' , receiveMessageFromWorker() for ClusterFuture ... done [12:32:23.253] | : . ' , ; ` | : . ' , receiveMessageFromWorker() returned object of class FutureResult; resolved [12:32:23.253] | : . ' , ; ` | : . ' resolved() for ClusterFuture () ... done [12:32:23.253] | : . ' , ; ` | : . ' assertFutureResult() ... [12:32:23.253] | : . ' , ; ` | : . ' , Future uuid: 66e0468231a87fa5a50141bd001890da-3 [12:32:23.254] | : . ' , ; ` | : . ' , identical; success [12:32:23.254] | : . ' , ; ` | : . ' assertFutureResult() ... done [12:32:23.254] | : . ' , ; ` | : . resolved() ... done [12:32:23.255] | : . ' , ; ` | : . Future at position #1 is resolved ... [12:32:23.255] | : . ' , ; ` | : . ' value() for ClusterFuture () ... [12:32:23.255] | : . ' , ; ` | : . ' , result() for ClusterFuture ... [12:32:23.256] | : . ' , ; ` | : . ' , ; result already collected: FutureResult [12:32:23.256] | : . ' , ; ` | : . ' , result() for ClusterFuture ... done [12:32:23.256] | : . ' , ; ` | : . ' , result() for ClusterFuture ... [12:32:23.256] | : . ' , ; ` | : . ' , ; result already collected: FutureResult [12:32:23.257] | : . ' , ; ` | : . ' , result() for ClusterFuture ... done [12:32:23.257] | : . ' , ; ` | : . ' , signalConditions() ... [12:32:23.257] | : . ' , ; ` | : . ' , ; include = 'immediateCondition' [12:32:23.258] | : . ' , ; ` | : . ' , ; exclude = [12:32:23.258] | : . ' , ; ` | : . ' , ; resignal = FALSE [12:32:23.258] | : . ' , ; ` | : . ' , ; Number of conditions: 0 [12:32:23.258] | : . ' , ; ` | : . ' , ; int 0 [12:32:23.259] | : . ' , ; ` | : . ' , signalConditions() ... done [12:32:23.260] | : . ' , ; ` | : . ' , check for misuse ... [12:32:23.260] | : . ' , ; ` | : . ' , check for misuse ... done [12:32:23.260] | : . ' , ; ` | : . ' value() for ClusterFuture () ... done [12:32:23.261] | : . ' , ; ` | : . Future at position #1 is resolved ... done [12:32:23.261] | : . ' , ; ` | : collectValues('workers-37e5752128e4483a3ce8b7fda2d6c13d', firstOnly = TRUE) ... done [12:32:23.261] | : . ' , ; ` | : Remove collected futures ... [12:32:23.261] | : . ' , ; ` | : . Indices of futures to drop: [n=1] '1' [12:32:23.262] | : . ' , ; ` | : Remove collected futures ... done [12:32:23.262] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'collect-first', earlySignal = 1) ... done [12:32:23.262] | : . ' , ; ` | Early signaling of 1 future candidates ... [12:32:23.262] | : . ' , ; ` | Number of futures with early signaling requested: 0 [12:32:23.262] | : . ' , ; ` | Early signaling of 1 future candidates ... done [12:32:23.262] | : . ' , ; ` | Number of registered futures: 1 [12:32:23.263] | : . ' , ; ` Polling for a free worker ... done [12:32:23.263] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:23.263] | : . ' , ; ` | Listing all futures [12:32:23.263] | : . ' , ; ` | Number of registered futures: 0 [12:32:23.263] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:23.264] | : . ' , ; ` Total time: 0.121746063232422 [12:32:23.264] | : . ' , ; requestNode() ... done [12:32:23.264] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:23.265] | : . ' , ; ` Listing all futures [12:32:23.265] | : . ' , ; ` Number of registered futures: 0 [12:32:23.265] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:23.265] | : . ' , ; avail: [n=1] '1' [12:32:23.266] | : . ' , ; Index of first available worker: 1 [12:32:23.266] | : . ' , ; Validate that the worker is functional ... [12:32:23.267] | : . ' , ; ` Worker is functional [12:32:23.267] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:23.267] | : . ' , ; ` | Listing all futures [12:32:23.268] | : . ' , ; ` | Number of registered futures: 0 [12:32:23.268] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:23.268] | : . ' , ; Validate that the worker is functional ... done [12:32:23.268] | : . ' , requestWorker() ... done [12:32:23.269] | : . ' , cluster node index: 1 [12:32:23.269] | : . ' launchFuture() for ClusterFutureBackend ... done [12:32:23.269] | : . ' eraseGlobalEnvironment() ... [12:32:23.271] | : . ' eraseGlobalEnvironment() ... done [12:32:23.272] | : . ' launchFuture() ... [12:32:23.272] | : . ' , cluster node index: 1 [12:32:23.272] | : . ' , getFutureData() ... [12:32:23.273] | : . ' , ; getFutureCore() ... [12:32:23.273] | : . ' , ; ` Packages needed by the future expression (n = 0): [12:32:23.273] | : . ' , ; getFutureCore() ... done [12:32:23.274] | : . ' , ; getFutureCapture() ... [12:32:23.274] | : . ' , ; getFutureCapture() ... done [12:32:23.274] | : . ' , ; getFutureContext() ... [12:32:23.275] | : . ' , ; ` plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:23.275] | : . ' , ; ` | Getting stack without first backend: [n=0] [12:32:23.276] | : . ' , ; ` plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:23.276] | : . ' , ; ` Packages needed by future backend (n = 0): [12:32:23.276] | : . ' , ; getFutureContext() ... done [12:32:23.277] | : . ' , getFutureData() ... done [12:32:23.278] | : . ' , FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... [12:32:23.281] | : . ' , ; Appended future to position #1 [12:32:23.282] | : . ' , ; Number of registered futures: 1 [12:32:23.282] | : . ' , FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... done [12:32:23.283] | : . ' launchFuture() ... done [12:32:23.283] | : . ' ClusterFuture started [12:32:23.283] | : . Launching futures ... done [12:32:23.283] | : Using ClusterFutureBackend ... done [12:32:23.284] | : Future launched: 'ClusterFuture', 'MultiprocessFuture', 'Future' [12:32:23.284] | run() for 'Future' () ... done [12:32:23.284] future(..., label = NULL) ... done [12:32:23.285] value() for list ... [12:32:23.285] | recursive: 0 [12:32:23.285] | reduce: FALSE [12:32:23.285] | length: 2 [12:32:23.286] | Number of remaining objects: 2 [12:32:23.286] | checking value #1: [12:32:23.286] | 'obj' is ClusterFuture [12:32:23.286] | resolved() ... [12:32:23.287] | resolved() ... done [12:32:23.287] | ClusterFuture #1 [12:32:23.287] | signalConditionsASAP(ClusterFuture, pos=1) ... [12:32:23.287] | : nx: 2 [12:32:23.287] | : relay: TRUE [12:32:23.288] | : stdout: TRUE [12:32:23.288] | : signal: TRUE [12:32:23.288] | : resignal: FALSE [12:32:23.288] | : force: TRUE [12:32:23.288] | : relayed: [n=2] FALSE, FALSE [12:32:23.288] | : queued futures: [n=2] FALSE, FALSE [12:32:23.289] | : until=1 [12:32:23.289] | : relaying element #1 [12:32:23.289] | : value() for ClusterFuture () ... [12:32:23.289] | : . result() for ClusterFuture ... [12:32:23.289] | : . ' result already collected: FutureResult [12:32:23.290] | : . result() for ClusterFuture ... done [12:32:23.290] | : . result() for ClusterFuture ... [12:32:23.290] | : . ' result already collected: FutureResult [12:32:23.290] | : . result() for ClusterFuture ... done [12:32:23.290] | : . signalConditions() ... [12:32:23.291] | : . ' include = 'immediateCondition' [12:32:23.291] | : . ' exclude = [12:32:23.291] | : . ' resignal = FALSE [12:32:23.291] | : . ' Number of conditions: 0 [12:32:23.291] | : . ' int 0 [12:32:23.292] | : . signalConditions() ... done [12:32:23.292] | : . relay stdout ... [12:32:23.293] | : . relay stdout ... done [12:32:23.293] | : . check for misuse ... [12:32:23.293] | : . check for misuse ... done [12:32:23.293] | : value() for ClusterFuture () ... done [12:32:23.293] | : result() for ClusterFuture ... [12:32:23.294] | : . result already collected: FutureResult [12:32:23.294] | : result() for ClusterFuture ... done [12:32:23.294] | : signalConditions() ... [12:32:23.294] | : . include = 'immediateCondition' [12:32:23.294] | : . exclude = [12:32:23.295] | : . resignal = FALSE [12:32:23.295] | : . Number of conditions: 0 [12:32:23.295] | : . int 0 [12:32:23.296] | : signalConditions() ... done [12:32:23.296] | : result() for ClusterFuture ... [12:32:23.296] | : . result already collected: FutureResult [12:32:23.296] | : result() for ClusterFuture ... done [12:32:23.296] | : signalConditions() ... [12:32:23.296] | : . include = 'condition' [12:32:23.297] | : . exclude = 'error', 'immediateCondition' [12:32:23.297] | : . resignal = TRUE [12:32:23.297] | : . Number of conditions: 0 [12:32:23.297] | : . int 0 [12:32:23.298] | : signalConditions() ... done [12:32:23.298] | : relayed: [n=2] TRUE, FALSE [12:32:23.298] | : queued futures: [n=2] TRUE, FALSE [12:32:23.298] | signalConditionsASAP(ClusterFuture, pos=1) ... done [12:32:23.299] | value(, ...) ... [12:32:23.299] | value(, ...) ... done [12:32:23.299] | value() for ClusterFuture () ... [12:32:23.299] | : result() for ClusterFuture ... [12:32:23.299] | : . result already collected: FutureResult [12:32:23.300] | : result() for ClusterFuture ... done [12:32:23.300] | : result() for ClusterFuture ... [12:32:23.300] | : . result already collected: FutureResult [12:32:23.301] | : result() for ClusterFuture ... done [12:32:23.301] | : signalConditions() ... [12:32:23.301] | : . include = 'immediateCondition' [12:32:23.302] | : . exclude = [12:32:23.302] | : . resignal = FALSE [12:32:23.302] | : . Number of conditions: 0 [12:32:23.303] | : . int 0 [12:32:23.304] | : signalConditions() ... done [12:32:23.304] | : check for misuse ... [12:32:23.304] | : check for misuse ... done [12:32:23.305] | value() for ClusterFuture () ... done [12:32:23.305] | value: [12:32:23.305] | signalConditionsASAP(ClusterFuture, pos=1) ... [12:32:23.305] | : nx: 2 [12:32:23.306] | : relay: TRUE [12:32:23.306] | : stdout: TRUE [12:32:23.306] | : signal: TRUE [12:32:23.306] | : resignal: FALSE [12:32:23.306] | : force: TRUE [12:32:23.307] | : relayed: [n=2] TRUE, FALSE [12:32:23.307] | : queued futures: [n=2] TRUE, FALSE [12:32:23.307] | : until=2 [12:32:23.307] | : relaying element #2 [12:32:23.307] | : relayed: [n=2] TRUE, FALSE [12:32:23.308] | : queued futures: [n=2] TRUE, FALSE [12:32:23.308] | signalConditionsASAP(ClusterFuture, pos=1) ... done [12:32:23.308] | resolve() for ClusterFuture ... [12:32:23.309] | resolve() for ClusterFuture ... done [12:32:23.309] | length: 1 (resolved future 1) [12:32:23.310] value() for list ... done [12:32:23.310] checking value #2: [12:32:23.310] 'obj' is ClusterFuture [12:32:23.311] resolved() ... [12:32:23.311] | resolved() for ClusterFuture () ... [12:32:23.312] | : Cluster node socket connection: index=4, id=180 [12:32:23.312] | : assertValidConnection() ... [12:32:23.312] | : . cluster node index: 1 [12:32:23.313] | : assertValidConnection() ... done [12:32:23.314] | : receiveMessageFromWorker() for ClusterFuture ... [12:32:23.314] | : . cluster node index: 1 [12:32:23.314] | : . [1] TRUE [12:32:23.315] | : . Received data: [12:32:23.315] | : . List of 5 [12:32:23.315] | : . $ type : chr "VALUE" [12:32:23.315] | : . $ value :List of 16 [12:32:23.315] | : . ..$ value : int 2 [12:32:23.315] | : . ..$ visible : logi TRUE [12:32:23.315] | : . ..$ stdout : chr "" [12:32:23.315] | : . ..$ conditions : list() [12:32:23.315] | : . ..$ rng : logi FALSE [12:32:23.315] | : . ..$ seed : NULL [12:32:23.315] | : . ..$ misuseGlobalEnv : NULL [12:32:23.315] | : . ..$ misuseConnections :List of 3 [12:32:23.315] | : . .. ..$ added : NULL [12:32:23.315] | : . .. ..$ removed : NULL [12:32:23.315] | : . .. ..$ replaced: NULL [12:32:23.315] | : . ..$ misuseDevices : NULL [12:32:23.315] | : . ..$ misuseDefaultDevice: list() [12:32:23.315] | : . ..$ started : POSIXct[1:1], format: "2025-07-29 12:32:23" [12:32:23.315] | : . ..$ finished : POSIXct[1:1], format: "2025-07-29 12:32:23" [12:32:23.315] | : . ..$ uuid : chr [1:2] "66e0468231a87fa5a50141bd001890da" "4" [12:32:23.315] | : . ..$ session_uuid : chr "0e543e37a923b5a7603525f78e8264b1" [12:32:23.315] | : . .. ..- attr(*, "source")=List of 5 [12:32:23.315] | : . .. .. ..$ host : Named chr "CRANWIN3" [12:32:23.315] | : . .. .. .. ..- attr(*, "names")= chr "COMPUTERNAME" [12:32:23.315] | : . .. .. ..$ info : Named chr [1:9] "Windows" "Server x64" "build 20348" "CRANWIN3" ... [12:32:23.315] | : . .. .. .. ..- attr(*, "names")= chr [1:9] "sysname" "release" "version" "nodename" ... [12:32:23.315] | : . .. .. ..$ pid : int 150644 [12:32:23.315] | : . .. .. ..$ time : POSIXct[1:1], format: "2025-07-29 12:32:23" [12:32:23.315] | : . .. .. ..$ random: int 2147483647 [12:32:23.315] | : . ..$ r_info :List of 4 [12:32:23.315] | : . .. ..$ version :Classes 'R_system_version', 'package_version', 'numeric_version' hidden list of 1 [12:32:23.315] | : . .. .. ..$ : int [1:3] 4 6 0 [12:32:23.315] | : . .. ..$ os : chr "windows" [12:32:23.315] | : . .. ..$ os_name : chr "Windows" [12:32:23.315] | : . .. ..$ captures_utf8: logi TRUE [12:32:23.315] | : . ..$ version : chr "1.8" [12:32:23.315] | : . ..- attr(*, "class")= chr "FutureResult" [12:32:23.315] | : . $ success: logi TRUE [12:32:23.315] | : . $ time : 'proc_time' Named num [1:5] 0.02 0 0.02 NA NA [12:32:23.315] | : . ..- attr(*, "names")= chr [1:5] "user.self" "sys.self" "elapsed" "user.child" ... [12:32:23.315] | : . $ tag : NULL [12:32:23.333] | : . Received FutureResult [12:32:23.333] | : . FutureResult: [12:32:23.333] | : . value: 'integer' [12:32:23.333] | : . visible: TRUE [12:32:23.333] | : . stdout: character [12:32:23.333] | : . conditions: [n = 0] [12:32:23.333] | : . RNG used: FALSE [12:32:23.333] | : . duration: 0.00522995 secs (started 2025-07-29 12:32:23.278878) [12:32:23.333] | : . version: 1.8 [12:32:23.334] | : . FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... [12:32:23.334] | : . ' Removed future from position #1 [12:32:23.335] | : . ' Number of registered futures: 0 [12:32:23.335] | : . FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... done [12:32:23.335] | : . Erased future from future backend [12:32:23.336] | : . result() for ClusterFuture ... [12:32:23.336] | : . ' result already collected: FutureResult [12:32:23.336] | : . result() for ClusterFuture ... done [12:32:23.336] | : . signalConditions() ... [12:32:23.337] | : . ' include = 'immediateCondition' [12:32:23.337] | : . ' exclude = [12:32:23.337] | : . ' resignal = FALSE [12:32:23.338] | : . ' Number of conditions: 0 [12:32:23.338] | : . ' int 0 [12:32:23.339] | : . signalConditions() ... done [12:32:23.339] | : receiveMessageFromWorker() for ClusterFuture ... done [12:32:23.339] | : receiveMessageFromWorker() returned object of class FutureResult; resolved [12:32:23.339] | resolved() for ClusterFuture () ... done [12:32:23.340] | assertFutureResult() ... [12:32:23.340] | : Future uuid: 66e0468231a87fa5a50141bd001890da-4 [12:32:23.340] | : identical; success [12:32:23.340] | assertFutureResult() ... done [12:32:23.341] resolved() ... done [12:32:23.341] ClusterFuture #2 [12:32:23.341] signalConditionsASAP(ClusterFuture, pos=2) ... [12:32:23.341] | nx: 2 [12:32:23.342] | relay: TRUE [12:32:23.342] | stdout: TRUE [12:32:23.342] | signal: TRUE [12:32:23.342] | resignal: FALSE [12:32:23.343] | force: TRUE [12:32:23.343] | relayed: [n=2] TRUE, FALSE [12:32:23.343] | queued futures: [n=2] TRUE, FALSE [12:32:23.343] | until=2 [12:32:23.344] | relaying element #2 [12:32:23.344] | value() for ClusterFuture () ... [12:32:23.344] | : result() for ClusterFuture ... [12:32:23.345] | : . result already collected: FutureResult [12:32:23.345] | : result() for ClusterFuture ... done [12:32:23.345] | : result() for ClusterFuture ... [12:32:23.345] | : . result already collected: FutureResult [12:32:23.346] | : result() for ClusterFuture ... done [12:32:23.346] | : signalConditions() ... [12:32:23.346] | : . include = 'immediateCondition' [12:32:23.346] | : . exclude = [12:32:23.347] | : . resignal = FALSE [12:32:23.347] | : . Number of conditions: 0 [12:32:23.347] | : . int 0 [12:32:23.348] | : signalConditions() ... done [12:32:23.348] | : relay stdout ... [12:32:23.349] | : relay stdout ... done [12:32:23.349] | : check for misuse ... [12:32:23.349] | : check for misuse ... done [12:32:23.349] | value() for ClusterFuture () ... done [12:32:23.350] | result() for ClusterFuture ... [12:32:23.350] | : result already collected: FutureResult [12:32:23.350] | result() for ClusterFuture ... done [12:32:23.351] | signalConditions() ... [12:32:23.351] | : include = 'immediateCondition' [12:32:23.351] | : exclude = [12:32:23.351] | : resignal = FALSE [12:32:23.352] | : Number of conditions: 0 [12:32:23.352] | : int 0 [12:32:23.353] | signalConditions() ... done [12:32:23.353] | result() for ClusterFuture ... [12:32:23.353] | : result already collected: FutureResult [12:32:23.353] | result() for ClusterFuture ... done [12:32:23.354] | signalConditions() ... [12:32:23.354] | : include = 'condition' [12:32:23.354] | : exclude = 'error', 'immediateCondition' [12:32:23.354] | : resignal = TRUE [12:32:23.355] | : Number of conditions: 0 [12:32:23.355] | : int 0 [12:32:23.356] | signalConditions() ... done [12:32:23.356] | relayed: [n=2] TRUE, TRUE [12:32:23.356] | queued futures: [n=2] TRUE, TRUE [12:32:23.357] signalConditionsASAP(ClusterFuture, pos=2) ... done [12:32:23.357] value(, ...) ... [12:32:23.357] value(, ...) ... done [12:32:23.357] value() for ClusterFuture () ... [12:32:23.358] | result() for ClusterFuture ... [12:32:23.358] | : result already collected: FutureResult [12:32:23.358] | result() for ClusterFuture ... done [12:32:23.358] | result() for ClusterFuture ... [12:32:23.359] | : result already collected: FutureResult [12:32:23.359] | result() for ClusterFuture ... done [12:32:23.359] | signalConditions() ... [12:32:23.359] | : include = 'immediateCondition' [12:32:23.360] | : exclude = [12:32:23.360] | : resignal = FALSE [12:32:23.360] | : Number of conditions: 0 [12:32:23.360] | : int 0 [12:32:23.361] | signalConditions() ... done [12:32:23.362] | check for misuse ... [12:32:23.362] | check for misuse ... done [12:32:23.362] value() for ClusterFuture () ... done [12:32:23.362] value: [12:32:23.363] signalConditionsASAP(ClusterFuture, pos=2) ... [12:32:23.363] | nx: 2 [12:32:23.363] | relay: TRUE [12:32:23.363] | stdout: TRUE [12:32:23.364] | signal: TRUE [12:32:23.364] | resignal: FALSE [12:32:23.364] | force: TRUE [12:32:23.364] | relayed: [n=2] TRUE, TRUE [12:32:23.365] | queued futures: [n=2] TRUE, TRUE [12:32:23.365] | until=2 [12:32:23.365] | relayed: [n=2] TRUE, TRUE [12:32:23.365] | queued futures: [n=2] TRUE, TRUE [12:32:23.366] signalConditionsASAP(ClusterFuture, pos=2) ... done [12:32:23.366] resolve() for ClusterFuture ... [12:32:23.366] resolve() for ClusterFuture ... done [12:32:23.367] length: 0 (resolved future 2) [12:32:23.367] Relaying remaining futures ... [12:32:23.367] | signalConditionsASAP(NULL, pos=0) ... [12:32:23.367] | : nx: 2 [12:32:23.368] | : relay: TRUE [12:32:23.368] | : stdout: TRUE [12:32:23.368] | : signal: TRUE [12:32:23.368] | : resignal: FALSE [12:32:23.368] | : force: TRUE [12:32:23.369] | : relayed: [n=2] TRUE, TRUE [12:32:23.369] | : queued futures: [n=2] TRUE, TRUE - flush all [12:32:23.369] | : relayed: [n=2] TRUE, TRUE [12:32:23.370] | : queued futures: [n=2] TRUE, TRUE [12:32:23.370] | signalConditionsASAP(NULL, pos=0) ... done [12:32:23.370] Relaying remaining futures ... done Iteration #3 [12:32:23.634] plan(<'name'>, .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:23.635] | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = NA, init = TRUE) ... [12:32:23.635] | : all.equal() for FutureStrategyList ... [12:32:23.636] | : . New stack: [12:32:23.636] | : . List of 1 [12:32:23.636] | : . $ :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:23.636] | : . ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:23.636] | : . ..- attr(*, "init")= logi TRUE [12:32:23.636] | : . ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:23.636] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:23.636] | : . .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.636] | : . ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.636] | : . ..- attr(*, "tweaks")=List of 1 [12:32:23.636] | : . .. ..$ workers:List of 1 [12:32:23.636] | : . .. .. ..$ :List of 3 [12:32:23.636] | : . .. .. .. ..$ con : 'sockconn' int 4 [12:32:23.636] | : . .. .. .. .. ..- attr(*, "conn_id")= [12:32:23.636] | : . .. .. .. ..$ host: chr "localhost" [12:32:23.636] | : . .. .. .. ..$ rank: num 0 [12:32:23.636] | : . .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:23.636] | : . .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:23.636] | : . ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:23.636] | : . - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:23.645] | : . Old stack: [12:32:23.645] | : . List of 1 [12:32:23.645] | : . $ :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:23.645] | : . ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:23.645] | : . ..- attr(*, "init")= chr "done" [12:32:23.645] | : . ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:23.645] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:23.645] | : . .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.645] | : . ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.645] | : . ..- attr(*, "tweaks")=List of 1 [12:32:23.645] | : . .. ..$ workers:List of 1 [12:32:23.645] | : . .. .. ..$ :List of 3 [12:32:23.645] | : . .. .. .. ..$ con : 'sockconn' int 4 [12:32:23.645] | : . .. .. .. .. ..- attr(*, "conn_id")= [12:32:23.645] | : . .. .. .. ..$ host: chr "localhost" [12:32:23.645] | : . .. .. .. ..$ rank: num 0 [12:32:23.645] | : . .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:23.645] | : . .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:23.645] | : . ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:23.645] | : . ..- attr(*, "backend")=Classes 'ClusterFutureBackend', 'MultiprocessFutureBackend', 'FutureBackend', 'environment' [12:32:23.645] | : . .. ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:23.645] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:23.645] | : . .. .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.645] | : . - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:23.656] | : . Not identical [12:32:23.656] | : . all.equal() for future ... [12:32:23.656] | : . ' List of 2 [12:32:23.656] | : . ' $ target :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:23.656] | : . ' ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:23.656] | : . ' ..- attr(*, "init")= logi TRUE [12:32:23.656] | : . ' ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:23.656] | : . ' earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:23.656] | : . ' .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.656] | : . ' ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.656] | : . ' ..- attr(*, "tweaks")=List of 1 [12:32:23.656] | : . ' .. ..$ workers:List of 1 [12:32:23.656] | : . ' .. .. ..$ :List of 3 [12:32:23.656] | : . ' .. .. .. ..$ con : 'sockconn' int 4 [12:32:23.656] | : . ' .. .. .. .. ..- attr(*, "conn_id")= [12:32:23.656] | : . ' .. .. .. ..$ host: chr "localhost" [12:32:23.656] | : . ' .. .. .. ..$ rank: num 0 [12:32:23.656] | : . ' .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:23.656] | : . ' .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:23.656] | : . ' ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:23.656] | : . ' $ current:function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:23.656] | : . ' ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:23.656] | : . ' ..- attr(*, "init")= chr "done" [12:32:23.656] | : . ' ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:23.656] | : . ' earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:23.656] | : . ' .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.656] | : . ' ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.656] | : . ' ..- attr(*, "tweaks")=List of 1 [12:32:23.656] | : . ' .. ..$ workers:List of 1 [12:32:23.656] | : . ' .. .. ..$ :List of 3 [12:32:23.656] | : . ' .. .. .. ..$ con : 'sockconn' int 4 [12:32:23.656] | : . ' .. .. .. .. ..- attr(*, "conn_id")= [12:32:23.656] | : . ' .. .. .. ..$ host: chr "localhost" [12:32:23.656] | : . ' .. .. .. ..$ rank: num 0 [12:32:23.656] | : . ' .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:23.656] | : . ' .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:23.656] | : . ' ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:23.656] | : . ' ..- attr(*, "backend")=Classes 'ClusterFutureBackend', 'MultiprocessFutureBackend', 'FutureBackend', 'environment' [12:32:23.656] | : . ' .. ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:23.656] | : . ' earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:23.656] | : . ' .. .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.675] | : . ' Formals differ [12:32:23.675] | : . all.equal() for future ... done [12:32:23.676] | : . Future strategies differ at level 1 [12:32:23.676] | : all.equal() for FutureStrategyList ... done [12:32:23.676] | : plan(): Setting new future backend stack: [12:32:23.676] | : List of future strategies: [12:32:23.676] | : 1. cluster: [12:32:23.676] | : - args: function (..., workers = "") [12:32:23.676] | : - tweaked: TRUE [12:32:23.676] | : - call: plan(cluster, workers = cl) [12:32:23.677] | : List of 1 [12:32:23.677] | : $ :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:23.677] | : ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:23.677] | : ..- attr(*, "init")= logi TRUE [12:32:23.677] | : ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:23.677] | : earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:23.677] | : .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.677] | : ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.677] | : ..- attr(*, "tweaks")=List of 1 [12:32:23.677] | : .. ..$ workers:List of 1 [12:32:23.677] | : .. .. ..$ :List of 3 [12:32:23.677] | : .. .. .. ..$ con : 'sockconn' int 4 [12:32:23.677] | : .. .. .. .. ..- attr(*, "conn_id")= [12:32:23.677] | : .. .. .. ..$ host: chr "localhost" [12:32:23.677] | : .. .. .. ..$ rank: num 0 [12:32:23.677] | : .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:23.677] | : .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:23.677] | : ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:23.677] | : - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:23.689] | : plan(): plan_cleanup(<'tweaked', 'cluster', 'multiprocess', 'future', 'function'>, cleanup = NA) ... [12:32:23.689] | : . plan("next", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:23.690] | : . ' Getting current ("next") strategy: 'FutureStrategy', 'tweaked', 'cluster', 'multiprocess', 'future', 'function' [12:32:23.690] | : . plan("next", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:23.690] | : . stopWorkers() for ClusterFutureBackend ... [12:32:23.690] | : . ' Interrupt active futures ... [12:32:23.691] | : . ' , Number of futures: 0 [12:32:23.691] | : . ' Interrupt active futures ... done [12:32:23.692] | : . ' Clear future registry ... [12:32:23.693] | : . ' Clear future registry ... done [12:32:23.693] | : . ' Stop cluster workers ... [12:32:23.693] | : . ' , Stopping existing cluster ... [12:32:23.693] | : . ' , ; No pre-existing cluster. Skipping [12:32:23.694] | : . ' , Stopping existing cluster ... done [12:32:23.694] | : . ' Stop cluster workers ... done [12:32:23.694] | : . stopWorkers() for ClusterFutureBackend ... done [12:32:23.694] | : . Legacy shutdown of cluster workers ... [12:32:23.694] | : . ' Stopping existing cluster ... [12:32:23.695] | : . ' , No pre-existing cluster. Skipping [12:32:23.695] | : . ' Stopping existing cluster ... done [12:32:23.695] | : . Legacy shutdown of cluster workers ... done [12:32:23.695] | : plan(): plan_cleanup(<'tweaked', 'cluster', 'multiprocess', 'future', 'function'>, cleanup = NA) ... done [12:32:23.696] | : plan(): plan_init() of 'tweaked', 'cluster', 'multiprocess', 'future', 'function' ... [12:32:23.696] | : . function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:23.696] | : . - attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:23.696] | : . - attr(*, "init")= logi TRUE [12:32:23.696] | : . - attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:23.696] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:23.696] | : . ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.696] | : . - attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:23.696] | : . - attr(*, "tweaks")=List of 1 [12:32:23.696] | : . ..$ workers:List of 1 [12:32:23.696] | : . .. ..$ :List of 3 [12:32:23.696] | : . .. .. ..$ con : 'sockconn' int 4 [12:32:23.696] | : . .. .. .. ..- attr(*, "conn_id")= [12:32:23.696] | : . .. .. ..$ host: chr "localhost" [12:32:23.696] | : . .. .. ..$ rank: num 0 [12:32:23.696] | : . .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:23.696] | : . .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:23.696] | : . - attr(*, "call")= language plan(cluster, workers = cl) [12:32:23.704] | : . init: TRUE [12:32:23.704] | : . makeFutureBackend() ... [12:32:23.704] | : . ' Backend function: <'NULL'> [12:32:23.705] | : . ' Evaluator tweak arguments: [n=1] [12:32:23.705] | : . ' List of 1 [12:32:23.705] | : . ' $ workers:List of 1 [12:32:23.705] | : . ' ..$ :List of 3 [12:32:23.705] | : . ' .. ..$ con : 'sockconn' int 4 [12:32:23.705] | : . ' .. .. ..- attr(*, "conn_id")= [12:32:23.705] | : . ' .. ..$ host: chr "localhost" [12:32:23.705] | : . ' .. ..$ rank: num 0 [12:32:23.705] | : . ' .. ..- attr(*, "class")= chr "SOCKnode" [12:32:23.705] | : . ' ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:23.710] | : . ' Evaluator formal arguments: [n=1] [12:32:23.710] | : . ' List of 1 [12:32:23.710] | : . ' $ workers:List of 1 [12:32:23.710] | : . ' ..$ :List of 3 [12:32:23.710] | : . ' .. ..$ con : 'sockconn' int 4 [12:32:23.710] | : . ' .. .. ..- attr(*, "conn_id")= [12:32:23.710] | : . ' .. ..$ host: chr "localhost" [12:32:23.710] | : . ' .. ..$ rank: num 0 [12:32:23.710] | : . ' .. ..- attr(*, "class")= chr "SOCKnode" [12:32:23.710] | : . ' ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:23.714] | : . ' Backend factory arguments: [n=1] [12:32:23.715] | : . ' Dotted pair list of 1 [12:32:23.715] | : . ' $ workers:List of 1 [12:32:23.715] | : . ' ..$ :List of 3 [12:32:23.715] | : . ' .. ..$ con : 'sockconn' int 4 [12:32:23.715] | : . ' .. .. ..- attr(*, "conn_id")= [12:32:23.715] | : . ' .. ..$ host: chr "localhost" [12:32:23.715] | : . ' .. ..$ rank: num 0 [12:32:23.715] | : . ' .. ..- attr(*, "class")= chr "SOCKnode" [12:32:23.715] | : . ' ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:23.719] | : . ' ClusterFutureBackend(..., persistent = FALSE, gc = TRUE, earlySignal = TRUE) ... [12:32:23.720] | : . ' , Stopping existing cluster ... [12:32:23.720] | : . ' , ; No pre-existing cluster. Skipping [12:32:23.720] | : . ' , Stopping existing cluster ... done [12:32:23.720] | : . ' , Number of workers: 1 [12:32:23.721] | : . ' , Generated workers UUID [12:32:23.721] | : . ' , Workers UUID: '37e5752128e4483a3ce8b7fda2d6c13d' [12:32:23.721] | : . ' ClusterFutureBackend(..., persistent = FALSE, gc = TRUE, earlySignal = TRUE) ... done [12:32:23.722] | : . ' Backend: <'ClusterFutureBackend', 'MultiprocessFutureBackend', 'FutureBackend', 'environment'> [12:32:23.722] | : . makeFutureBackend() ... done [12:32:23.722] | : plan(): plan_init() of 'tweaked', 'cluster', 'multiprocess', 'future', 'function' ... done [12:32:23.722] | : nbrOfWorkers(NULL) ... [12:32:23.723] | : . List of 4 [12:32:23.723] | : . $ : language plan_set(newStack, skip = .skip, cleanup = .cleanup, init = .init, debug = debug) [12:32:23.723] | : . $ : language with_assert({ nbrOfWorkers <- nbrOfWorkers() ... [12:32:23.723] | : . $ : language nbrOfWorkers() [12:32:23.723] | : . $ : language nbrOfWorkers.NULL() [12:32:23.725] | : . plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:23.726] | : . plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:23.726] | : . Number of workers: 1 [12:32:23.726] | : nbrOfWorkers(NULL) ... done [12:32:23.726] | : plan(): nbrOfWorkers() = 1 [12:32:23.727] | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = NA, init = TRUE) ... done [12:32:23.727] plan(<'name'>, .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:23.727] future(..., label = NULL) ... [12:32:23.728] | lazy: FALSE [12:32:23.728] | stdout: TRUE [12:32:23.728] | conditions: [n=1] 'condition' [12:32:23.728] | gc: FALSE [12:32:23.729] | earlySignal: FALSE [12:32:23.729] | getGlobalsAndPackages() ... [12:32:23.729] | : Searching for globals ... [12:32:23.736] | : . globals found: [3] '[[', 'X', 'i' [12:32:23.736] | : Searching for globals ... done [12:32:23.737] | : Resolving globals: FALSE [12:32:23.737] | : Search for packages associated with the globals ... [12:32:23.737] | : . Packages associated with globals: [1] 'base' [12:32:23.738] | : . Packages: [1] 'base' [12:32:23.738] | : Search for packages associated with the globals ... done [12:32:23.738] | : Packages after dropping 'base': [0] [12:32:23.739] | : globals: [2] 'X', 'i' [12:32:23.739] | : packages: [0] [12:32:23.739] | getGlobalsAndPackages() ... done [12:32:23.740] | run() for 'Future' () ... [12:32:23.740] | : state: 'created' [12:32:23.740] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:23.740] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:23.741] | : Using ClusterFutureBackend ... [12:32:23.741] | : . Number of futures since start: 0 (0 created, 0 launched, 0 finished) [12:32:23.741] | : . Launching futures ... [12:32:23.742] | : . ' launchFuture() for ClusterFutureBackend ... [12:32:23.742] | : . ' , Workers: [n=1] [12:32:23.742] | : . ' , socket cluster with 1 nodes on host 'localhost' [12:32:23.743] | : . ' , FutureRegistry: 'workers-37e5752128e4483a3ce8b7fda2d6c13d' [12:32:23.743] | : . ' , requestWorker() ... [12:32:23.743] | : . ' , ; requestNode() ... [12:32:23.744] | : . ' , ; ` Number of workers: 1 [12:32:23.744] | : . ' , ; ` Polling for a free worker ... [12:32:23.744] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:23.744] | : . ' , ; ` | : Listing all futures [12:32:23.745] | : . ' , ; ` | : Number of registered futures: 0 [12:32:23.745] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:23.745] | : . ' , ; ` | Total time: 0 [12:32:23.745] | : . ' , ; ` Polling for a free worker ... done [12:32:23.746] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:23.746] | : . ' , ; ` | Listing all futures [12:32:23.746] | : . ' , ; ` | Number of registered futures: 0 [12:32:23.746] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:23.747] | : . ' , ; ` avail: [n=1] '1' [12:32:23.747] | : . ' , ; ` Index of first available worker: 1 [12:32:23.747] | : . ' , ; ` Validate that the worker is functional ... [12:32:23.748] | : . ' , ; ` | Worker is functional [12:32:23.748] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:23.748] | : . ' , ; ` | : Listing all futures [12:32:23.749] | : . ' , ; ` | : Number of registered futures: 0 [12:32:23.749] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:23.749] | : . ' , ; ` Validate that the worker is functional ... done [12:32:23.750] | : . ' , ; requestNode() ... done [12:32:23.750] | : . ' , ; cluster node index: 1 [12:32:23.750] | : . ' , requestWorker() ... done [12:32:23.750] | : . ' , eraseGlobalEnvironment() ... [12:32:23.879] | : . ' , eraseGlobalEnvironment() ... done [12:32:23.879] | : . ' , launchFuture() ... [12:32:23.880] | : . ' , ; cluster node index: 1 [12:32:23.880] | : . ' , ; getFutureData() ... [12:32:23.880] | : . ' , ; ` getFutureCore() ... [12:32:23.881] | : . ' , ; ` | Packages needed by the future expression (n = 0): [12:32:23.881] | : . ' , ; ` getFutureCore() ... done [12:32:23.881] | : . ' , ; ` getFutureCapture() ... [12:32:23.882] | : . ' , ; ` getFutureCapture() ... done [12:32:23.882] | : . ' , ; ` getFutureContext() ... [12:32:23.882] | : . ' , ; ` | plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:23.883] | : . ' , ; ` | : Getting stack without first backend: [n=0] [12:32:23.883] | : . ' , ; ` | plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:23.883] | : . ' , ; ` | Packages needed by future backend (n = 0): [12:32:23.884] | : . ' , ; ` getFutureContext() ... done [12:32:23.884] | : . ' , ; getFutureData() ... done [12:32:23.885] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... [12:32:23.885] | : . ' , ; ` Appended future to position #1 [12:32:23.886] | : . ' , ; ` Number of registered futures: 1 [12:32:23.886] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... done [12:32:23.886] | : . ' , launchFuture() ... done [12:32:23.887] | : . ' , ClusterFuture started [12:32:23.887] | : . ' launchFuture() for ClusterFutureBackend ... done [12:32:23.887] | : . Launching futures ... done [12:32:23.888] | : . Future launched: 'ClusterFuture', 'MultiprocessFuture', 'Future' [12:32:23.888] | : Using ClusterFutureBackend ... done [12:32:23.888] | run() for 'Future' () ... done [12:32:23.889] future(..., label = NULL) ... done [12:32:23.889] future(..., label = NULL) ... [12:32:23.889] | lazy: FALSE [12:32:23.889] | stdout: TRUE [12:32:23.890] | conditions: [n=1] 'condition' [12:32:23.890] | gc: FALSE [12:32:23.890] | earlySignal: FALSE [12:32:23.891] | getGlobalsAndPackages() ... [12:32:23.891] | : Searching for globals ... [12:32:23.898] | : . globals found: [3] '[[', 'X', 'i' [12:32:23.899] | : Searching for globals ... done [12:32:23.899] | : Resolving globals: FALSE [12:32:23.899] | : Search for packages associated with the globals ... [12:32:23.899] | : . Packages associated with globals: [1] 'base' [12:32:23.900] | : . Packages: [1] 'base' [12:32:23.900] | : Search for packages associated with the globals ... done [12:32:23.900] | : Packages after dropping 'base': [0] [12:32:23.900] | : globals: [2] 'X', 'i' [12:32:23.901] | : packages: [0] [12:32:23.901] | getGlobalsAndPackages() ... done [12:32:23.901] | run() for 'Future' () ... [12:32:23.901] | : state: 'created' [12:32:23.902] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:23.902] | : plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:23.902] | : Using ClusterFutureBackend ... [12:32:23.902] | : . Number of futures since start: 1 (1 created, 1 launched, 0 finished) [12:32:23.902] | : . Launching futures ... [12:32:23.903] | : . ' launchFuture() for ClusterFutureBackend ... [12:32:23.903] | : . ' , Workers: [n=1] [12:32:23.903] | : . ' , socket cluster with 1 nodes on host 'localhost' [12:32:23.904] | : . ' , FutureRegistry: 'workers-37e5752128e4483a3ce8b7fda2d6c13d' [12:32:23.904] | : . ' , requestWorker() ... [12:32:23.904] | : . ' , ; requestNode() ... [12:32:23.904] | : . ' , ; ` Number of workers: 1 [12:32:23.904] | : . ' , ; ` Polling for a free worker ... [12:32:23.905] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:23.905] | : . ' , ; ` | : Listing all futures [12:32:23.905] | : . ' , ; ` | : Number of registered futures: 1 [12:32:23.905] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:23.905] | : . ' , ; ` | Poll #1 (0): usedNodes() = 1, workers = 1 [12:32:23.925] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'collect-first', earlySignal = 1) ... [12:32:23.925] | : . ' , ; ` | : collectValues('workers-37e5752128e4483a3ce8b7fda2d6c13d', firstOnly = TRUE) ... [12:32:23.926] | : . ' , ; ` | : . resolved() ... [12:32:23.926] | : . ' , ; ` | : . ' resolved() for ClusterFuture () ... [12:32:23.927] | : . ' , ; ` | : . ' , Cluster node socket connection: index=4, id=221 [12:32:23.927] | : . ' , ; ` | : . ' , assertValidConnection() ... [12:32:23.928] | : . ' , ; ` | : . ' , ; cluster node index: 1 [12:32:23.928] | : . ' , ; ` | : . ' , assertValidConnection() ... done [12:32:23.965] | : . ' , ; ` | : . ' , receiveMessageFromWorker() for ClusterFuture ... [12:32:23.966] | : . ' , ; ` | : . ' , ; cluster node index: 1 [12:32:23.967] | : . ' , ; ` | : . ' , ; [1] TRUE [12:32:23.967] | : . ' , ; ` | : . ' , ; Received data: [12:32:23.968] | : . ' , ; ` | : . ' , ; List of 5 [12:32:23.968] | : . ' , ; ` | : . ' , ; $ type : chr "VALUE" [12:32:23.968] | : . ' , ; ` | : . ' , ; $ value :List of 16 [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ value : int 1 [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ visible : logi TRUE [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ stdout : chr "" [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ conditions : list() [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ rng : logi FALSE [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ seed : NULL [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ misuseGlobalEnv : NULL [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ misuseConnections :List of 3 [12:32:23.968] | : . ' , ; ` | : . ' , ; .. ..$ added : NULL [12:32:23.968] | : . ' , ; ` | : . ' , ; .. ..$ removed : NULL [12:32:23.968] | : . ' , ; ` | : . ' , ; .. ..$ replaced: NULL [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ misuseDevices : NULL [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ misuseDefaultDevice: list() [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ started : POSIXct[1:1], format: "2025-07-29 12:32:23" [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ finished : POSIXct[1:1], format: "2025-07-29 12:32:23" [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ uuid : chr [1:2] "66e0468231a87fa5a50141bd001890da" "5" [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ session_uuid : chr "e0824bc874292e6dcdd6303411f1cc0b" [12:32:23.968] | : . ' , ; ` | : . ' , ; .. ..- attr(*, "source")=List of 5 [12:32:23.968] | : . ' , ; ` | : . ' , ; .. .. ..$ host : Named chr "CRANWIN3" [12:32:23.968] | : . ' , ; ` | : . ' , ; .. .. .. ..- attr(*, "names")= chr "COMPUTERNAME" [12:32:23.968] | : . ' , ; ` | : . ' , ; .. .. ..$ info : Named chr [1:9] "Windows" "Server x64" "build 20348" "CRANWIN3" ... [12:32:23.968] | : . ' , ; ` | : . ' , ; .. .. .. ..- attr(*, "names")= chr [1:9] "sysname" "release" "version" "nodename" ... [12:32:23.968] | : . ' , ; ` | : . ' , ; .. .. ..$ pid : int 157124 [12:32:23.968] | : . ' , ; ` | : . ' , ; .. .. ..$ time : POSIXct[1:1], format: "2025-07-29 12:32:23" [12:32:23.968] | : . ' , ; ` | : . ' , ; .. .. ..$ random: int 2147483647 [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ r_info :List of 4 [12:32:23.968] | : . ' , ; ` | : . ' , ; .. ..$ version :Classes 'R_system_version', 'package_version', 'numeric_version' hidden list of 1 [12:32:23.968] | : . ' , ; ` | : . ' , ; .. .. ..$ : int [1:3] 4 6 0 [12:32:23.968] | : . ' , ; ` | : . ' , ; .. ..$ os : chr "windows" [12:32:23.968] | : . ' , ; ` | : . ' , ; .. ..$ os_name : chr "Windows" [12:32:23.968] | : . ' , ; ` | : . ' , ; .. ..$ captures_utf8: logi TRUE [12:32:23.968] | : . ' , ; ` | : . ' , ; ..$ version : chr "1.8" [12:32:23.968] | : . ' , ; ` | : . ' , ; ..- attr(*, "class")= chr "FutureResult" [12:32:23.968] | : . ' , ; ` | : . ' , ; $ success: logi TRUE [12:32:23.968] | : . ' , ; ` | : . ' , ; $ time : 'proc_time' Named num [1:5] 0.08 0 0.07 NA NA [12:32:23.968] | : . ' , ; ` | : . ' , ; ..- attr(*, "names")= chr [1:5] "user.self" "sys.self" "elapsed" "user.child" ... [12:32:23.968] | : . ' , ; ` | : . ' , ; $ tag : NULL [12:32:23.994] | : . ' , ; ` | : . ' , ; Received FutureResult [12:32:23.995] | : . ' , ; ` | : . ' , ; FutureResult: [12:32:23.995] | : . ' , ; ` | : . ' , ; value: 'integer' [12:32:23.995] | : . ' , ; ` | : . ' , ; visible: TRUE [12:32:23.995] | : . ' , ; ` | : . ' , ; stdout: character [12:32:23.995] | : . ' , ; ` | : . ' , ; conditions: [n = 0] [12:32:23.995] | : . ' , ; ` | : . ' , ; RNG used: FALSE [12:32:23.995] | : . ' , ; ` | : . ' , ; duration: 0.07674384 secs (started 2025-07-29 12:32:23.887397) [12:32:23.995] | : . ' , ; ` | : . ' , ; version: 1.8 [12:32:23.996] | : . ' , ; ` | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... [12:32:23.996] | : . ' , ; ` | : . ' , ; ` Removed future from position #1 [12:32:23.997] | : . ' , ; ` | : . ' , ; ` Number of registered futures: 0 [12:32:23.997] | : . ' , ; ` | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... done [12:32:23.997] | : . ' , ; ` | : . ' , ; Erased future from future backend [12:32:23.998] | : . ' , ; ` | : . ' , ; result() for ClusterFuture ... [12:32:23.998] | : . ' , ; ` | : . ' , ; ` result already collected: FutureResult [12:32:23.998] | : . ' , ; ` | : . ' , ; result() for ClusterFuture ... done [12:32:23.999] | : . ' , ; ` | : . ' , ; signalConditions() ... [12:32:23.999] | : . ' , ; ` | : . ' , ; ` include = 'immediateCondition' [12:32:24.000] | : . ' , ; ` | : . ' , ; ` exclude = [12:32:24.000] | : . ' , ; ` | : . ' , ; ` resignal = FALSE [12:32:24.000] | : . ' , ; ` | : . ' , ; ` Number of conditions: 0 [12:32:24.001] | : . ' , ; ` | : . ' , ; ` int 0 [12:32:24.001] | : . ' , ; ` | : . ' , ; signalConditions() ... done [12:32:24.002] | : . ' , ; ` | : . ' , receiveMessageFromWorker() for ClusterFuture ... done [12:32:24.002] | : . ' , ; ` | : . ' , receiveMessageFromWorker() returned object of class FutureResult; resolved [12:32:24.002] | : . ' , ; ` | : . ' resolved() for ClusterFuture () ... done [12:32:24.003] | : . ' , ; ` | : . ' assertFutureResult() ... [12:32:24.003] | : . ' , ; ` | : . ' , Future uuid: 66e0468231a87fa5a50141bd001890da-5 [12:32:24.004] | : . ' , ; ` | : . ' , identical; success [12:32:24.004] | : . ' , ; ` | : . ' assertFutureResult() ... done [12:32:24.004] | : . ' , ; ` | : . resolved() ... done [12:32:24.005] | : . ' , ; ` | : . Future at position #1 is resolved ... [12:32:24.005] | : . ' , ; ` | : . ' value() for ClusterFuture () ... [12:32:24.005] | : . ' , ; ` | : . ' , result() for ClusterFuture ... [12:32:24.006] | : . ' , ; ` | : . ' , ; result already collected: FutureResult [12:32:24.006] | : . ' , ; ` | : . ' , result() for ClusterFuture ... done [12:32:24.006] | : . ' , ; ` | : . ' , result() for ClusterFuture ... [12:32:24.007] | : . ' , ; ` | : . ' , ; result already collected: FutureResult [12:32:24.007] | : . ' , ; ` | : . ' , result() for ClusterFuture ... done [12:32:24.007] | : . ' , ; ` | : . ' , signalConditions() ... [12:32:24.008] | : . ' , ; ` | : . ' , ; include = 'immediateCondition' [12:32:24.008] | : . ' , ; ` | : . ' , ; exclude = [12:32:24.008] | : . ' , ; ` | : . ' , ; resignal = FALSE [12:32:24.009] | : . ' , ; ` | : . ' , ; Number of conditions: 0 [12:32:24.009] | : . ' , ; ` | : . ' , ; int 0 [12:32:24.010] | : . ' , ; ` | : . ' , signalConditions() ... done [12:32:24.011] | : . ' , ; ` | : . ' , check for misuse ... [12:32:24.011] | : . ' , ; ` | : . ' , check for misuse ... done [12:32:24.011] | : . ' , ; ` | : . ' value() for ClusterFuture () ... done [12:32:24.012] | : . ' , ; ` | : . Future at position #1 is resolved ... done [12:32:24.012] | : . ' , ; ` | : collectValues('workers-37e5752128e4483a3ce8b7fda2d6c13d', firstOnly = TRUE) ... done [12:32:24.013] | : . ' , ; ` | : Remove collected futures ... [12:32:24.013] | : . ' , ; ` | : . Indices of futures to drop: [n=1] '1' [12:32:24.013] | : . ' , ; ` | : Remove collected futures ... done [12:32:24.014] | : . ' , ; ` | FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'collect-first', earlySignal = 1) ... done [12:32:24.014] | : . ' , ; ` | Early signaling of 1 future candidates ... [12:32:24.014] | : . ' , ; ` | Number of futures with early signaling requested: 0 [12:32:24.015] | : . ' , ; ` | Early signaling of 1 future candidates ... done [12:32:24.015] | : . ' , ; ` | Number of registered futures: 1 [12:32:24.015] | : . ' , ; ` Polling for a free worker ... done [12:32:24.016] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:24.016] | : . ' , ; ` | Listing all futures [12:32:24.016] | : . ' , ; ` | Number of registered futures: 0 [12:32:24.017] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:24.017] | : . ' , ; ` Total time: 0.111073970794678 [12:32:24.017] | : . ' , ; requestNode() ... done [12:32:24.018] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:24.018] | : . ' , ; ` Listing all futures [12:32:24.018] | : . ' , ; ` Number of registered futures: 0 [12:32:24.019] | : . ' , ; FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:24.019] | : . ' , ; avail: [n=1] '1' [12:32:24.019] | : . ' , ; Index of first available worker: 1 [12:32:24.020] | : . ' , ; Validate that the worker is functional ... [12:32:24.021] | : . ' , ; ` Worker is functional [12:32:24.021] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... [12:32:24.021] | : . ' , ; ` | Listing all futures [12:32:24.021] | : . ' , ; ` | Number of registered futures: 0 [12:32:24.022] | : . ' , ; ` FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'list', earlySignal = 0) ... done [12:32:24.022] | : . ' , ; Validate that the worker is functional ... done [12:32:24.022] | : . ' , requestWorker() ... done [12:32:24.023] | : . ' , cluster node index: 1 [12:32:24.023] | : . ' launchFuture() for ClusterFutureBackend ... done [12:32:24.023] | : . ' eraseGlobalEnvironment() ... [12:32:24.024] | : . ' eraseGlobalEnvironment() ... done [12:32:24.024] | : . ' launchFuture() ... [12:32:24.025] | : . ' , cluster node index: 1 [12:32:24.025] | : . ' , getFutureData() ... [12:32:24.025] | : . ' , ; getFutureCore() ... [12:32:24.026] | : . ' , ; ` Packages needed by the future expression (n = 0): [12:32:24.026] | : . ' , ; getFutureCore() ... done [12:32:24.026] | : . ' , ; getFutureCapture() ... [12:32:24.026] | : . ' , ; getFutureCapture() ... done [12:32:24.027] | : . ' , ; getFutureContext() ... [12:32:24.027] | : . ' , ; ` plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:24.027] | : . ' , ; ` | Getting stack without first backend: [n=0] [12:32:24.028] | : . ' , ; ` plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:24.028] | : . ' , ; ` Packages needed by future backend (n = 0): [12:32:24.028] | : . ' , ; getFutureContext() ... done [12:32:24.029] | : . ' , getFutureData() ... done [12:32:24.030] | : . ' , FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... [12:32:24.030] | : . ' , ; Appended future to position #1 [12:32:24.030] | : . ' , ; Number of registered futures: 1 [12:32:24.031] | : . ' , FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'add', earlySignal = 0) ... done [12:32:24.031] | : . ' launchFuture() ... done [12:32:24.031] | : . ' ClusterFuture started [12:32:24.031] | : . Launching futures ... done [12:32:24.032] | : Using ClusterFutureBackend ... done [12:32:24.032] | : Future launched: 'ClusterFuture', 'MultiprocessFuture', 'Future' [12:32:24.032] | run() for 'Future' () ... done [12:32:24.033] future(..., label = NULL) ... done [12:32:24.033] value() for list ... [12:32:24.033] | recursive: 0 [12:32:24.034] | reduce: FALSE [12:32:24.034] | length: 2 [12:32:24.035] | Number of remaining objects: 2 [12:32:24.035] | checking value #1: [12:32:24.035] | 'obj' is ClusterFuture [12:32:24.038] | resolved() ... [12:32:24.038] | resolved() ... done [12:32:24.039] | ClusterFuture #1 [12:32:24.039] | signalConditionsASAP(ClusterFuture, pos=1) ... [12:32:24.039] | : nx: 2 [12:32:24.039] | : relay: TRUE [12:32:24.040] | : stdout: TRUE [12:32:24.040] | : signal: TRUE [12:32:24.040] | : resignal: FALSE [12:32:24.040] | : force: TRUE [12:32:24.041] | : relayed: [n=2] FALSE, FALSE [12:32:24.041] | : queued futures: [n=2] FALSE, FALSE [12:32:24.041] | : until=1 [12:32:24.041] | : relaying element #1 [12:32:24.042] | : value() for ClusterFuture () ... [12:32:24.042] | : . result() for ClusterFuture ... [12:32:24.042] | : . ' result already collected: FutureResult [12:32:24.043] | : . result() for ClusterFuture ... done [12:32:24.043] | : . result() for ClusterFuture ... [12:32:24.043] | : . ' result already collected: FutureResult [12:32:24.043] | : . result() for ClusterFuture ... done [12:32:24.044] | : . signalConditions() ... [12:32:24.044] | : . ' include = 'immediateCondition' [12:32:24.044] | : . ' exclude = [12:32:24.044] | : . ' resignal = FALSE [12:32:24.045] | : . ' Number of conditions: 0 [12:32:24.045] | : . ' int 0 [12:32:24.046] | : . signalConditions() ... done [12:32:24.046] | : . relay stdout ... [12:32:24.046] | : . relay stdout ... done [12:32:24.047] | : . check for misuse ... [12:32:24.047] | : . check for misuse ... done [12:32:24.047] | : value() for ClusterFuture () ... done [12:32:24.048] | : result() for ClusterFuture ... [12:32:24.048] | : . result already collected: FutureResult [12:32:24.048] | : result() for ClusterFuture ... done [12:32:24.048] | : signalConditions() ... [12:32:24.049] | : . include = 'immediateCondition' [12:32:24.049] | : . exclude = [12:32:24.049] | : . resignal = FALSE [12:32:24.049] | : . Number of conditions: 0 [12:32:24.050] | : . int 0 [12:32:24.051] | : signalConditions() ... done [12:32:24.051] | : result() for ClusterFuture ... [12:32:24.051] | : . result already collected: FutureResult [12:32:24.051] | : result() for ClusterFuture ... done [12:32:24.052] | : signalConditions() ... [12:32:24.052] | : . include = 'condition' [12:32:24.052] | : . exclude = 'error', 'immediateCondition' [12:32:24.052] | : . resignal = TRUE [12:32:24.053] | : . Number of conditions: 0 [12:32:24.053] | : . int 0 [12:32:24.054] | : signalConditions() ... done [12:32:24.054] | : relayed: [n=2] TRUE, FALSE [12:32:24.054] | : queued futures: [n=2] TRUE, FALSE [12:32:24.055] | signalConditionsASAP(ClusterFuture, pos=1) ... done [12:32:24.055] | value(, ...) ... [12:32:24.055] | value(, ...) ... done [12:32:24.055] | value() for ClusterFuture () ... [12:32:24.056] | : result() for ClusterFuture ... [12:32:24.056] | : . result already collected: FutureResult [12:32:24.056] | : result() for ClusterFuture ... done [12:32:24.057] | : result() for ClusterFuture ... [12:32:24.057] | : . result already collected: FutureResult [12:32:24.057] | : result() for ClusterFuture ... done [12:32:24.057] | : signalConditions() ... [12:32:24.058] | : . include = 'immediateCondition' [12:32:24.058] | : . exclude = [12:32:24.058] | : . resignal = FALSE [12:32:24.059] | : . Number of conditions: 0 [12:32:24.059] | : . int 0 [12:32:24.060] | : signalConditions() ... done [12:32:24.060] | : check for misuse ... [12:32:24.060] | : check for misuse ... done [12:32:24.061] | value() for ClusterFuture () ... done [12:32:24.061] | value: [12:32:24.061] | signalConditionsASAP(ClusterFuture, pos=1) ... [12:32:24.061] | : nx: 2 [12:32:24.062] | : relay: TRUE [12:32:24.062] | : stdout: TRUE [12:32:24.062] | : signal: TRUE [12:32:24.062] | : resignal: FALSE [12:32:24.063] | : force: TRUE [12:32:24.063] | : relayed: [n=2] TRUE, FALSE [12:32:24.063] | : queued futures: [n=2] TRUE, FALSE [12:32:24.063] | : until=2 [12:32:24.064] | : relaying element #2 [12:32:24.064] | : relayed: [n=2] TRUE, FALSE [12:32:24.064] | : queued futures: [n=2] TRUE, FALSE [12:32:24.065] | signalConditionsASAP(ClusterFuture, pos=1) ... done [12:32:24.065] | resolve() for ClusterFuture ... [12:32:24.065] | resolve() for ClusterFuture ... done [12:32:24.065] | length: 1 (resolved future 1) [12:32:24.066] value() for list ... done [12:32:24.066] checking value #2: [12:32:24.066] 'obj' is ClusterFuture [12:32:24.067] resolved() ... [12:32:24.067] | resolved() for ClusterFuture () ... [12:32:24.067] | : Cluster node socket connection: index=4, id=221 [12:32:24.068] | : assertValidConnection() ... [12:32:24.068] | : . cluster node index: 1 [12:32:24.069] | : assertValidConnection() ... done [12:32:24.069] | : receiveMessageFromWorker() for ClusterFuture ... [12:32:24.069] | : . cluster node index: 1 [12:32:24.070] | : . [1] TRUE [12:32:24.070] | : . Received data: [12:32:24.070] | : . List of 5 [12:32:24.070] | : . $ type : chr "VALUE" [12:32:24.070] | : . $ value :List of 16 [12:32:24.070] | : . ..$ value : int 2 [12:32:24.070] | : . ..$ visible : logi TRUE [12:32:24.070] | : . ..$ stdout : chr "" [12:32:24.070] | : . ..$ conditions : list() [12:32:24.070] | : . ..$ rng : logi FALSE [12:32:24.070] | : . ..$ seed : NULL [12:32:24.070] | : . ..$ misuseGlobalEnv : NULL [12:32:24.070] | : . ..$ misuseConnections :List of 3 [12:32:24.070] | : . .. ..$ added : NULL [12:32:24.070] | : . .. ..$ removed : NULL [12:32:24.070] | : . .. ..$ replaced: NULL [12:32:24.070] | : . ..$ misuseDevices : NULL [12:32:24.070] | : . ..$ misuseDefaultDevice: list() [12:32:24.070] | : . ..$ started : POSIXct[1:1], format: "2025-07-29 12:32:24" [12:32:24.070] | : . ..$ finished : POSIXct[1:1], format: "2025-07-29 12:32:24" [12:32:24.070] | : . ..$ uuid : chr [1:2] "66e0468231a87fa5a50141bd001890da" "6" [12:32:24.070] | : . ..$ session_uuid : chr "e0824bc874292e6dcdd6303411f1cc0b" [12:32:24.070] | : . .. ..- attr(*, "source")=List of 5 [12:32:24.070] | : . .. .. ..$ host : Named chr "CRANWIN3" [12:32:24.070] | : . .. .. .. ..- attr(*, "names")= chr "COMPUTERNAME" [12:32:24.070] | : . .. .. ..$ info : Named chr [1:9] "Windows" "Server x64" "build 20348" "CRANWIN3" ... [12:32:24.070] | : . .. .. .. ..- attr(*, "names")= chr [1:9] "sysname" "release" "version" "nodename" ... [12:32:24.070] | : . .. .. ..$ pid : int 157124 [12:32:24.070] | : . .. .. ..$ time : POSIXct[1:1], format: "2025-07-29 12:32:23" [12:32:24.070] | : . .. .. ..$ random: int 2147483647 [12:32:24.070] | : . ..$ r_info :List of 4 [12:32:24.070] | : . .. ..$ version :Classes 'R_system_version', 'package_version', 'numeric_version' hidden list of 1 [12:32:24.070] | : . .. .. ..$ : int [1:3] 4 6 0 [12:32:24.070] | : . .. ..$ os : chr "windows" [12:32:24.070] | : . .. ..$ os_name : chr "Windows" [12:32:24.070] | : . .. ..$ captures_utf8: logi TRUE [12:32:24.070] | : . ..$ version : chr "1.8" [12:32:24.070] | : . ..- attr(*, "class")= chr "FutureResult" [12:32:24.070] | : . $ success: logi TRUE [12:32:24.070] | : . $ time : 'proc_time' Named num [1:5] 0.02 0 0.01 NA NA [12:32:24.070] | : . ..- attr(*, "names")= chr [1:5] "user.self" "sys.self" "elapsed" "user.child" ... [12:32:24.070] | : . $ tag : NULL [12:32:24.092] | : . Received FutureResult [12:32:24.092] | : . FutureResult: [12:32:24.092] | : . value: 'integer' [12:32:24.092] | : . visible: TRUE [12:32:24.092] | : . stdout: character [12:32:24.092] | : . conditions: [n = 0] [12:32:24.092] | : . RNG used: FALSE [12:32:24.092] | : . duration: 0.006009817 secs (started 2025-07-29 12:32:24.030373) [12:32:24.092] | : . version: 1.8 [12:32:24.093] | : . FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... [12:32:24.093] | : . ' Removed future from position #1 [12:32:24.094] | : . ' Number of registered futures: 0 [12:32:24.094] | : . FutureRegistry('workers-37e5752128e4483a3ce8b7fda2d6c13d', action = 'remove', earlySignal = 0) ... done [12:32:24.094] | : . Erased future from future backend [12:32:24.094] | : . result() for ClusterFuture ... [12:32:24.095] | : . ' result already collected: FutureResult [12:32:24.095] | : . result() for ClusterFuture ... done [12:32:24.095] | : . signalConditions() ... [12:32:24.096] | : . ' include = 'immediateCondition' [12:32:24.096] | : . ' exclude = [12:32:24.096] | : . ' resignal = FALSE [12:32:24.096] | : . ' Number of conditions: 0 [12:32:24.097] | : . ' int 0 [12:32:24.097] | : . signalConditions() ... done [12:32:24.098] | : receiveMessageFromWorker() for ClusterFuture ... done [12:32:24.098] | : receiveMessageFromWorker() returned object of class FutureResult; resolved [12:32:24.098] | resolved() for ClusterFuture () ... done [12:32:24.098] | assertFutureResult() ... [12:32:24.099] | : Future uuid: 66e0468231a87fa5a50141bd001890da-6 [12:32:24.099] | : identical; success [12:32:24.099] | assertFutureResult() ... done [12:32:24.100] resolved() ... done [12:32:24.100] ClusterFuture #2 [12:32:24.100] signalConditionsASAP(ClusterFuture, pos=2) ... [12:32:24.100] | nx: 2 [12:32:24.100] | relay: TRUE [12:32:24.101] | stdout: TRUE [12:32:24.101] | signal: TRUE [12:32:24.101] | resignal: FALSE [12:32:24.101] | force: TRUE [12:32:24.101] | relayed: [n=2] TRUE, FALSE [12:32:24.102] | queued futures: [n=2] TRUE, FALSE [12:32:24.102] | until=2 [12:32:24.102] | relaying element #2 [12:32:24.102] | value() for ClusterFuture () ... [12:32:24.103] | : result() for ClusterFuture ... [12:32:24.103] | : . result already collected: FutureResult [12:32:24.103] | : result() for ClusterFuture ... done [12:32:24.103] | : result() for ClusterFuture ... [12:32:24.104] | : . result already collected: FutureResult [12:32:24.104] | : result() for ClusterFuture ... done [12:32:24.104] | : signalConditions() ... [12:32:24.104] | : . include = 'immediateCondition' [12:32:24.104] | : . exclude = [12:32:24.105] | : . resignal = FALSE [12:32:24.105] | : . Number of conditions: 0 [12:32:24.105] | : . int 0 [12:32:24.106] | : signalConditions() ... done [12:32:24.106] | : relay stdout ... [12:32:24.107] | : relay stdout ... done [12:32:24.107] | : check for misuse ... [12:32:24.107] | : check for misuse ... done [12:32:24.107] | value() for ClusterFuture () ... done [12:32:24.108] | result() for ClusterFuture ... [12:32:24.108] | : result already collected: FutureResult [12:32:24.108] | result() for ClusterFuture ... done [12:32:24.109] | signalConditions() ... [12:32:24.109] | : include = 'immediateCondition' [12:32:24.109] | : exclude = [12:32:24.109] | : resignal = FALSE [12:32:24.110] | : Number of conditions: 0 [12:32:24.110] | : int 0 [12:32:24.111] | signalConditions() ... done [12:32:24.111] | result() for ClusterFuture ... [12:32:24.111] | : result already collected: FutureResult [12:32:24.111] | result() for ClusterFuture ... done [12:32:24.112] | signalConditions() ... [12:32:24.112] | : include = 'condition' [12:32:24.112] | : exclude = 'error', 'immediateCondition' [12:32:24.113] | : resignal = TRUE [12:32:24.113] | : Number of conditions: 0 [12:32:24.113] | : int 0 [12:32:24.114] | signalConditions() ... done [12:32:24.114] | relayed: [n=2] TRUE, TRUE [12:32:24.115] | queued futures: [n=2] TRUE, TRUE [12:32:24.115] signalConditionsASAP(ClusterFuture, pos=2) ... done [12:32:24.115] value(, ...) ... [12:32:24.116] value(, ...) ... done [12:32:24.116] value() for ClusterFuture () ... [12:32:24.116] | result() for ClusterFuture ... [12:32:24.117] | : result already collected: FutureResult [12:32:24.117] | result() for ClusterFuture ... done [12:32:24.117] | result() for ClusterFuture ... [12:32:24.118] | : result already collected: FutureResult [12:32:24.118] | result() for ClusterFuture ... done [12:32:24.118] | signalConditions() ... [12:32:24.119] | : include = 'immediateCondition' [12:32:24.119] | : exclude = [12:32:24.119] | : resignal = FALSE [12:32:24.119] | : Number of conditions: 0 [12:32:24.120] | : int 0 [12:32:24.121] | signalConditions() ... done [12:32:24.121] | check for misuse ... [12:32:24.121] | check for misuse ... done [12:32:24.122] value() for ClusterFuture () ... done [12:32:24.122] value: [12:32:24.122] signalConditionsASAP(ClusterFuture, pos=2) ... [12:32:24.123] | nx: 2 [12:32:24.123] | relay: TRUE [12:32:24.123] | stdout: TRUE [12:32:24.124] | signal: TRUE [12:32:24.124] | resignal: FALSE [12:32:24.124] | force: TRUE [12:32:24.125] | relayed: [n=2] TRUE, TRUE [12:32:24.125] | queued futures: [n=2] TRUE, TRUE [12:32:24.125] | until=2 [12:32:24.126] | relayed: [n=2] TRUE, TRUE [12:32:24.126] | queued futures: [n=2] TRUE, TRUE [12:32:24.126] signalConditionsASAP(ClusterFuture, pos=2) ... done [12:32:24.127] resolve() for ClusterFuture ... [12:32:24.127] resolve() for ClusterFuture ... done [12:32:24.127] length: 0 (resolved future 2) [12:32:24.128] Relaying remaining futures ... [12:32:24.128] | signalConditionsASAP(NULL, pos=0) ... [12:32:24.128] | : nx: 2 [12:32:24.129] | : relay: TRUE [12:32:24.129] | : stdout: TRUE [12:32:24.129] | : signal: TRUE [12:32:24.130] | : resignal: FALSE [12:32:24.130] | : force: TRUE [12:32:24.130] | : relayed: [n=2] TRUE, TRUE [12:32:24.131] | : queued futures: [n=2] TRUE, TRUE - flush all [12:32:24.131] | : relayed: [n=2] TRUE, TRUE [12:32:24.131] | : queued futures: [n=2] TRUE, TRUE [12:32:24.132] | signalConditionsASAP(NULL, pos=0) ... done [12:32:24.132] Relaying remaining futures ... done > plan(sequential) [12:32:24.139] plan(<'name'>, .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:24.139] | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = NA, init = TRUE) ... [12:32:24.140] | : all.equal() for FutureStrategyList ... [12:32:24.140] | : . New stack: [12:32:24.140] | : . List of 1 [12:32:24.140] | : . $ :function (..., envir = parent.frame()) [12:32:24.140] | : . ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function" [12:32:24.140] | : . ..- attr(*, "init")= logi TRUE [12:32:24.140] | : . ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf) [12:32:24.140] | : . .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:24.140] | : . ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:24.140] | : . ..- attr(*, "call")= language plan(sequential) [12:32:24.140] | : . - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:24.146] | : . Old stack: [12:32:24.147] | : . List of 1 [12:32:24.147] | : . $ :function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:24.147] | : . ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:24.147] | : . ..- attr(*, "init")= chr "done" [12:32:24.147] | : . ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:24.147] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:24.147] | : . .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:24.147] | : . ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:24.147] | : . ..- attr(*, "tweaks")=List of 1 [12:32:24.147] | : . .. ..$ workers:List of 1 [12:32:24.147] | : . .. .. ..$ :List of 3 [12:32:24.147] | : . .. .. .. ..$ con : 'sockconn' int 4 [12:32:24.147] | : . .. .. .. .. ..- attr(*, "conn_id")= [12:32:24.147] | : . .. .. .. ..$ host: chr "localhost" [12:32:24.147] | : . .. .. .. ..$ rank: num 0 [12:32:24.147] | : . .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:24.147] | : . .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:24.147] | : . ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:24.147] | : . ..- attr(*, "backend")=Classes 'ClusterFutureBackend', 'MultiprocessFutureBackend', 'FutureBackend', 'environment' [12:32:24.147] | : . .. ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:24.147] | : . earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:24.147] | : . .. .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:24.147] | : . - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:24.161] | : . Not identical [12:32:24.161] | : . all.equal() for future ... [12:32:24.161] | : . ' List of 2 [12:32:24.161] | : . ' $ target :function (..., envir = parent.frame()) [12:32:24.161] | : . ' ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function" [12:32:24.161] | : . ' ..- attr(*, "init")= logi TRUE [12:32:24.161] | : . ' ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf) [12:32:24.161] | : . ' .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:24.161] | : . ' ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:24.161] | : . ' ..- attr(*, "call")= language plan(sequential) [12:32:24.161] | : . ' $ current:function (..., workers = list(list(con = 4L, host = "localhost", rank = 0))) [12:32:24.161] | : . ' ..- attr(*, "class")= chr [1:5] "tweaked" "cluster" "multiprocess" "future" ... [12:32:24.161] | : . ' ..- attr(*, "init")= chr "done" [12:32:24.161] | : . ' ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:24.161] | : . ' earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:24.161] | : . ' .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:24.161] | : . ' ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:24.161] | : . ' ..- attr(*, "tweaks")=List of 1 [12:32:24.161] | : . ' .. ..$ workers:List of 1 [12:32:24.161] | : . ' .. .. ..$ :List of 3 [12:32:24.161] | : . ' .. .. .. ..$ con : 'sockconn' int 4 [12:32:24.161] | : . ' .. .. .. .. ..- attr(*, "conn_id")= [12:32:24.161] | : . ' .. .. .. ..$ host: chr "localhost" [12:32:24.161] | : . ' .. .. .. ..$ rank: num 0 [12:32:24.161] | : . ' .. .. .. ..- attr(*, "class")= chr "SOCKnode" [12:32:24.161] | : . ' .. .. ..- attr(*, "class")= chr [1:2] "SOCKcluster" "cluster" [12:32:24.161] | : . ' ..- attr(*, "call")= language plan(cluster, workers = cl) [12:32:24.161] | : . ' ..- attr(*, "backend")=Classes 'ClusterFutureBackend', 'MultiprocessFutureBackend', 'FutureBackend', 'environment' [12:32:24.161] | : . ' .. ..- attr(*, "factory")=function (workers = availableWorkers(constraints = "connections"), gc = TRUE, [12:32:24.161] | : . ' earlySignal = TRUE, interrupts = FALSE, persistent = FALSE, ...) [12:32:24.161] | : . ' .. .. ..- attr(*, "tweakable")= chr [1:9] "gc" "earlySignal" "interrupts" "persistent" ... [12:32:24.178] | : . ' Formals differ [12:32:24.178] | : . all.equal() for future ... done [12:32:24.179] | : . Future strategies differ at level 1 [12:32:24.179] | : all.equal() for FutureStrategyList ... done [12:32:24.179] | : plan(): Setting new future backend stack: [12:32:24.179] | : List of future strategies: [12:32:24.179] | : 1. sequential: [12:32:24.179] | : - args: function (..., envir = parent.frame(), workers = "") [12:32:24.179] | : - tweaked: FALSE [12:32:24.179] | : - call: plan(sequential) [12:32:24.180] | : List of 1 [12:32:24.180] | : $ :function (..., envir = parent.frame()) [12:32:24.180] | : ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function" [12:32:24.180] | : ..- attr(*, "init")= logi TRUE [12:32:24.180] | : ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf) [12:32:24.180] | : .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:24.180] | : ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:24.180] | : ..- attr(*, "call")= language plan(sequential) [12:32:24.180] | : - attr(*, "class")= chr [1:2] "FutureStrategyList" "list" [12:32:24.184] | : plan(): plan_cleanup(<'tweaked', 'cluster', 'multiprocess', 'future', 'function'>, cleanup = NA) ... [12:32:24.184] | : . plan("next", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:24.184] | : . ' Getting current ("next") strategy: 'FutureStrategy', 'tweaked', 'cluster', 'multiprocess', 'future', 'function' [12:32:24.184] | : . plan("next", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:24.185] | : . stopWorkers() for ClusterFutureBackend ... [12:32:24.185] | : . ' Interrupt active futures ... [12:32:24.186] | : . ' , Number of futures: 0 [12:32:24.186] | : . ' Interrupt active futures ... done [12:32:24.186] | : . ' Clear future registry ... [12:32:24.187] | : . ' Clear future registry ... done [12:32:24.187] | : . ' Stop cluster workers ... [12:32:24.187] | : . ' , Stopping existing cluster ... [12:32:24.187] | : . ' , ; No pre-existing cluster. Skipping [12:32:24.187] | : . ' , Stopping existing cluster ... done [12:32:24.188] | : . ' Stop cluster workers ... done [12:32:24.188] | : . stopWorkers() for ClusterFutureBackend ... done [12:32:24.188] | : . Legacy shutdown of cluster workers ... [12:32:24.188] | : . ' Stopping existing cluster ... [12:32:24.188] | : . ' , No pre-existing cluster. Skipping [12:32:24.189] | : . ' Stopping existing cluster ... done [12:32:24.189] | : . Legacy shutdown of cluster workers ... done [12:32:24.189] | : plan(): plan_cleanup(<'tweaked', 'cluster', 'multiprocess', 'future', 'function'>, cleanup = NA) ... done [12:32:24.189] | : plan(): plan_init() of 'sequential', 'uniprocess', 'future', 'function' ... [12:32:24.189] | : . function (..., envir = parent.frame()) [12:32:24.189] | : . - attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function" [12:32:24.189] | : . - attr(*, "init")= logi TRUE [12:32:24.189] | : . - attr(*, "factory")=function (..., maxSizeOfObjects = +Inf) [12:32:24.189] | : . ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:24.189] | : . - attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ... [12:32:24.189] | : . - attr(*, "call")= language plan(sequential) [12:32:24.193] | : . init: TRUE [12:32:24.193] | : . makeFutureBackend() ... [12:32:24.194] | : . ' Backend function: <'NULL'> [12:32:24.194] | : . ' Evaluator tweak arguments: [n=0] [12:32:24.194] | : . ' list() [12:32:24.195] | : . ' Evaluator formal arguments: [n=0] [12:32:24.195] | : . ' list() [12:32:24.195] | : . ' Backend factory arguments: [n=0] [12:32:24.195] | : . ' NULL [12:32:24.196] | : . ' Backend: <'SequentialFutureBackend', 'FutureBackend', 'environment'> [12:32:24.196] | : . makeFutureBackend() ... done [12:32:24.196] | : plan(): plan_init() of 'sequential', 'uniprocess', 'future', 'function' ... done [12:32:24.197] | : nbrOfWorkers(NULL) ... [12:32:24.197] | : . List of 4 [12:32:24.197] | : . $ : language plan_set(newStack, skip = .skip, cleanup = .cleanup, init = .init, debug = debug) [12:32:24.197] | : . $ : language with_assert({ nbrOfWorkers <- nbrOfWorkers() ... [12:32:24.197] | : . $ : language nbrOfWorkers() [12:32:24.197] | : . $ : language nbrOfWorkers.NULL() [12:32:24.199] | : . plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... [12:32:24.199] | : . plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done [12:32:24.200] | : . Number of workers: 1 [12:32:24.200] | : nbrOfWorkers(NULL) ... done [12:32:24.200] | : plan(): nbrOfWorkers() = 1 [12:32:24.200] | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = NA, init = TRUE) ... done [12:32:24.200] plan(<'name'>, .skip = FALSE, .cleanup = NA, .init = TRUE) ... done > message("all.equal() for cluster backend ... done") all.equal() for cluster backend ... done Sourcing 6 epilogue scripts ... 01/06 epilogue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_epilogue/001.undo-future.R' 02/06 epilogue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_epilogue/002.undo-state.R' Failed to undo environment variables: - Expected environment variables: [n=213] '!ExitCode', 'ALLUSERSPROFILE', 'APPDATA', 'BIBINPUTS', 'BINDIR', 'BSTINPUTS', 'COMMONPROGRAMFILES', 'COMPUTERNAME', 'COMSPEC', 'CURL_CA_BUNDLE', 'CYGWIN', 'CommonProgramFiles(x86)', 'CommonProgramW6432', 'DriverData', 'HOME', 'HOMEDRIVE', 'HOMEPATH', 'JAGS_ROOT', 'JAVA_HOME', 'LANGUAGE', 'LC_COLLATE', 'LC_MONETARY', 'LC_TIME', 'LOCALAPPDATA', 'LOGONSERVER', 'LS_HOME', 'LS_LICENSE_PATH', 'MAKE', 'MAKEFLAGS', 'MAKELEVEL', 'MFLAGS', 'MSMPI_BENCHMARKS', 'MSMPI_BIN', 'MSYS2_ENV_CONV_EXCL', 'NUMBER_OF_PROCESSORS', 'OCL', 'OMP_THREAD_LIMIT', 'OS', 'PATH', 'PATHEXT', 'PROCESSOR_ARCHITECTURE', 'PROCESSOR_IDENTIFIER', 'PROCESSOR_LEVEL', 'PROCESSOR_REVISION', 'PROGRAMFILES', 'PROMPT', 'PSModulePath', 'PUBLIC', 'PWD', 'ProgramData', 'ProgramFiles(x86)', 'ProgramW6432', 'RTOOLS44_HOME', 'RTOOLS45_HOME', 'R_ARCH', 'R_BROWSER', 'R_BZIPCMD', 'R_CMD', 'R_COMPILED_BY', 'R_CRAN_WEB', 'R_CUSTOM_TOOLS_PATH', 'R_CUSTOM_TOOLS_SOFT', 'R_DOC_DIR', 'R_ENVIRON_USER', 'R_GSCMD', 'R_GZIPCMD', 'R_HOME', 'R_INCLUDE_DIR', 'R_INSTALL_TAR', 'R_LIBS', 'R_LIBS_SITE', 'R_LIBS_USER', 'R_MAX_NUM_DLLS', 'R_OSTYPE', 'R_PAPERSIZE', 'R_PAPERSIZE_USER', 'R_PARALLELLY_MAKENODEPSOCK_AUTOKILL', 'R_PARALLELLY_MAKENODEPSOCK_CONNECTTIMEOUT', 'R_PARALLELLY_MAKENODEPSOCK_RSCRIPT_LABEL', 'R_PARALLELLY_MAKENODEPSOCK_SESSIONINFO_PKGS', 'R_PARALLELLY_MAKENODEPSOCK_TIMEOUT', 'R_PARALLELLY_RANDOM_PORTS', 'R_PARALLEL_PORT', 'R_RD4PDF', 'R_RTOOLS45_PATH', 'R_SCRIPT_LEGACY', 'R_SHARE_DIR', 'R_TESTME_NAME', 'R_TESTME_PACKAGE', 'R_TESTME_PATH', 'R_TESTS', 'R_UNZIPCMD', 'R_USER', 'R_VERSION', 'R_ZIPCMD', 'SED', 'SHLVL', 'SYSTEMDRIVE', 'SYSTEMROOT', 'TAR', 'TAR_OPTIONS', 'TEMP', 'TERM', 'TEXINPUTS', 'TMP', 'TMPDIR', 'USERDOMAIN', 'USERDOMAIN_ROAMINGPROFILE', 'USERNAME', 'USERPROFILE', 'WINDIR', '_', '_R_CHECK_AUTOCONF_', '_R_CHECK_BOGUS_RETURN_', '_R_CHECK_BROWSER_NONINTERACTIVE_', '_R_CHECK_BUILD_VIGNETTES_SEPARATELY_', '_R_CHECK_CODETOOLS_PROFILE_', '_R_CHECK_CODE_ASSIGN_TO_GLOBALENV_', '_R_CHECK_CODE_ATTACH_', '_R_CHECK_CODE_CLASS_IS_STRING_', '_R_CHECK_CODE_DATA_INTO_GLOBALENV_', '_R_CHECK_CODE_USAGE_VIA_NAMESPACES_', '_R_CHECK_CODE_USAGE_WITHOUT_LOADING_', '_R_CHECK_CODE_USAGE_WITH_ONLY_BASE_ATTACHED_', '_R_CHECK_CODOC_VARIABLES_IN_USAGES_', '_R_CHECK_COMPACT_DATA2_', '_R_CHECK_COMPILATION_FLAGS_', '_R_CHECK_CONNECTIONS_LEFT_OPEN_', '_R_CHECK_CRAN_INCOMING_', '_R_CHECK_CRAN_INCOMING_ASPELL_RECHECK_MAYBE_', '_R_CHECK_CRAN_INCOMING_ASPELL_RECHECK_START_', '_R_CHECK_CRAN_INCOMING_CHECK_FILE_URIS_', '_R_CHECK_CRAN_INCOMING_CHECK_URLS_IN_PARALLEL_', '_R_CHECK_CRAN_INCOMING_NOTE_GNU_MAKE_', '_R_CHECK_CRAN_INCOMING_REMOTE_', '_R_CHECK_CRAN_INCOMING_USE_ASPELL_', '_R_CHECK_DATALIST_', '_R_CHECK_DEPRECATED_DEFUNCT_', '_R_CHECK_DOC_SIZES2_', '_R_CHECK_DOT_FIRSTLIB_', '_R_CHECK_DOT_INTERNAL_', '_R_CHECK_EXAMPLE_TIMING_THRESHOLD_', '_R_CHECK_EXECUTABLES_', '_R_CHECK_EXECUTABLES_EXCLUSIONS_', '_R_CHECK_FF_CALLS_', '_R_CHECK_FF_DUP_', '_R_CHECK_FORCE_SUGGESTS_', '_R_CHECK_FUTURE_FILE_TIMESTAMPS_', '_R_CHECK_FUTURE_FILE_TIMESTAMPS_LEEWAY_', '_R_CHECK_HAVE_MYSQL_', '_R_CHECK_HAVE_ODBC_', '_R_CHECK_HAVE_PERL_', '_R_CHECK_HAVE_POSTGRES_', '_R_CHECK_INSTALL_DEPENDS_', '_R_CHECK_INTERNALS2_', '_R_CHECK_LENGTH_1_CONDITION_', '_R_CHECK_LICENSE_', '_R_CHECK_LIMIT_CORES_', '_R_CHECK_LOG_USE_INFO_', '_R_CHECK_MATRIX_DATA_', '_R_CHECK_MBCS_CONVERSION_FAILURE_', '_R_CHECK_NATIVE_ROUTINE_REGISTRATION_', '_R_CHECK_NEWS_IN_PLAIN_TEXT_', '_R_CHECK_NO_RECOMMENDED_', '_R_CHECK_NO_STOP_ON_TEST_ERROR_', '_R_CHECK_ORPHANED_', '_R_CHECK_OVERWRITE_REGISTERED_S3_METHODS_', '_R_CHECK_PACKAGES_USED_IGNORE_UNUSED_IMPORTS_', '_R_CHECK_PACKAGES_USED_IN_TESTS_USE_SUBDIRS_', '_R_CHECK_PACKAGE_DATASETS_SUPPRESS_NOTES_', '_R_CHECK_PACKAGE_NAME_', '_R_CHECK_PKG_SIZES_', '_R_CHECK_PKG_SIZES_THRESHOLD_', '_R_CHECK_PRAGMAS_', '_R_CHECK_RD_EXAMPLES_T_AND_F_', '_R_CHECK_RD_LINE_WIDTHS_', '_R_CHECK_RD_MATH_RENDERING_', '_R_CHECK_RD_NOTE_LOST_BRACES_', '_R_CHECK_RD_VALIDATE_RD2HTML_', '_R_CHECK_REPLACING_IMPORTS_', '_R_CHECK_R_DEPENDS_', '_R_CHECK_S3_METHODS_SHOW_POSSIBLE_ISSUES_', '_R_CHECK_SCREEN_DEVICE_', '_R_CHECK_SERIALIZATION_', '_R_CHECK_SHLIB_OPENMP_FLAGS_', '_R_CHECK_SRC_MINUS_W_IMPLICIT_', '_R_CHECK_SUBDIRS_NOCASE_', '_R_CHECK_SUGGESTS_ONLY_', '_R_CHECK_SYSTEM_CLOCK_', '_R_CHECK_TESTS_NLINES_', '_R_CHECK_TEST_TIMING_', '_R_CHECK_TIMINGS_', '_R_CHECK_TOPLEVEL_FILES_', '_R_CHECK_UNDOC_USE_ALL_NAMES_', '_R_CHECK_UNSAFE_CALLS_', '_R_CHECK_URLS_SHOW_301_STATUS_', '_R_CHECK_VC_DIRS_', '_R_CHECK_VIGNETTES_NLINES_', '_R_CHECK_VIGNETTES_SKIP_RUN_MAYBE_', '_R_CHECK_VIGNETTE_TIMING_', '_R_CHECK_VIGNETTE_TITLES_', '_R_CHECK_WINDOWS_DEVICE_', '_R_CHECK_XREFS_NOTE_MISSING_PACKAGE_ANCHORS_', '_R_CHECK_XREFS_USE_ALIASES_FROM_CRAN_', '_R_CLASS_MATRIX_ARRAY_', '_R_DEPRECATED_IS_R_', '_R_S3_METHOD_LOOKUP_BASEENV_AFTER_GLOBALENV_', '_R_SHLIB_BUILD_OBJECTS_SYMBOL_TABLES_', '_R_USE_STRICT_R_HEADERS_', '__R_CHECK_DOC_FILES_NOTE_IF_ALL_INTERNAL__', 'maj.version', 'nextArg--timingsnextArg--install', 'tempdirname' - Environment variables still there: [n=0] - Environment variables missing: [n=1] 'MAKEFLAGS' Differences environment variable by environment variable: 03/06 epilogue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_epilogue/090.gc.R' 04/06 epilogue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_epilogue/099.session_info.R' 05/06 epilogue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_epilogue/995.detritus-connections.R' 06/06 epilogue script 'D:/RCompile/CRANincoming/R-devel/lib/future/testme/_epilogue/999.detritus-files.R' Skipping, because path appears not to be an 'R CMD check' folder: 'D:/temp/2025_07_29_12_30_17_31216' Sourcing 6 epilogue scripts ... done Test time: user.self=1s, sys.self=0.08s, elapsed=3s, user.child=NAs, sys.child=NAs Test 'cluster-connection-clashes' ... success > > proc.time() user system elapsed 1.60 0.28 3.18