* using log directory 'd:/Rcompile/CRANpkg/local/4.6/doFuture.Rcheck' * using R Under development (unstable) (2025-04-16 r88149 ucrt) * using platform: x86_64-w64-mingw32 * R was compiled by gcc.exe (GCC) 14.2.0 GNU Fortran (GCC) 14.2.0 * running under: Windows Server 2022 x64 (build 20348) * using session charset: UTF-8 * checking for file 'doFuture/DESCRIPTION' ... OK * this is package 'doFuture' version '1.0.2' * package encoding: UTF-8 * checking package namespace information ... OK * checking package dependencies ... OK * checking if this is a source package ... OK * checking if there is a namespace ... OK * checking for hidden files and directories ... OK * checking for portable file names ... OK * checking whether package 'doFuture' can be installed ... OK * checking installed package size ... OK * checking package directory ... OK * checking 'build' directory ... OK * checking DESCRIPTION meta-information ... OK * checking top-level files ... OK * checking for left-over files ... OK * checking index information ... OK * checking package subdirectories ... OK * checking code files for non-ASCII characters ... OK * checking R files for syntax errors ... OK * checking whether the package can be loaded ... [1s] OK * checking whether the package can be loaded with stated dependencies ... [1s] OK * checking whether the package can be unloaded cleanly ... [1s] OK * checking whether the namespace can be loaded with stated dependencies ... [0s] OK * checking whether the namespace can be unloaded cleanly ... [1s] OK * checking loading without being on the library search path ... [1s] OK * checking whether startup messages can be suppressed ... [0s] OK * checking use of S3 registration ... OK * checking dependencies in R code ... OK * checking S3 generic/method consistency ... OK * checking replacement functions ... OK * checking foreign function calls ... OK * checking R code for possible problems ... [4s] OK * checking Rd files ... [1s] OK * checking Rd metadata ... OK * checking Rd cross-references ... OK * checking for missing documentation entries ... OK * checking for code/documentation mismatches ... OK * checking Rd \usage sections ... OK * checking Rd contents ... OK * checking for unstated dependencies in examples ... OK * checking installed files from 'inst/doc' ... OK * checking files in 'vignettes' ... OK * checking examples ... [1s] OK * checking for unstated dependencies in 'tests' ... OK * checking tests ... [256s] ERROR Running 'foreach_dofuture,cluster-missing-doFuture-pkg.R' [62s] Running 'foreach_dofuture,errors.R' [10s] Running 'foreach_dofuture,globals.R' [7s] Running 'foreach_dofuture,nested_colon.R' [14s] Running 'foreach_dofuture,nested_dofuture.R' [16s] Running 'foreach_dofuture,rng.R' [4s] Running 'foreach_dofuture.R' [3s] Running 'foreach_dopar,cluster-missing-doFuture-pkg.R' [62s] Running 'foreach_dopar,doRNG,dopar.R' [3s] Running 'foreach_dopar,doRNG,dorng.R' [6s] Running 'foreach_dopar,errors.R' [8s] Running 'foreach_dopar,globals.R' [7s] Running 'foreach_dopar,nested_colon.R' [13s] Running 'foreach_dopar,nested_dopar.R' [16s] Running 'foreach_dopar,options-for-export.R' [5s] Running 'foreach_dopar.R' [3s] Running 'makeChunks.R' [4s] Running 'options,nested.R' [4s] Running 'registerDoFuture.R' [2s] Running 'times.R' [2s] Running 'utils.R' [1s] Running 'withDoRNG.R' [4s] Running the tests in 'tests/foreach_dofuture,cluster-missing-doFuture-pkg.R' failed. Complete output: > source("incl/start.R") Loading required package: foreach Loading required package: future R Under development (unstable) (2025-04-16 r88149 ucrt) Platform: x86_64-w64-mingw32/x64 Running under: Windows Server 2022 x64 (build 20348) Matrix products: default LAPACK version 3.12.1 locale: [1] LC_COLLATE=C LC_CTYPE=German_Germany.utf8 [3] LC_MONETARY=C LC_NUMERIC=C [5] LC_TIME=C time zone: Europe/Berlin tzcode source: internal attached base packages: [1] stats graphics grDevices utils datasets methods base other attached packages: [1] doFuture_1.0.2 future_1.40.0 foreach_1.5.2 loaded via a namespace (and not attached): [1] compiler_4.6.0 parallelly_1.43.0 tools_4.6.0 [4] parallel_4.6.0 future.apply_1.11.3 listenv_0.9.1 [7] codetools_0.2-20 iterators_1.0.14 digest_0.6.37 [10] globals_0.17.0 > options(future.debug = FALSE) > > message("*** cluster() ...") *** cluster() ... > > message("Library paths: ", paste(sQuote(.libPaths()), collapse = ", ")) Library paths: 'D:/temp/2025_04_17_01_50_00_8240/RtmpA5Nt7O/RLIBS_2c6dc3ecf4a04', 'D:/RCompile/recent/R/library' > message("Package path: ", sQuote(system.file(package = "future"))) Package path: 'D:/RCompile/CRANpkg/lib/4.6/future' > > types <- "PSOCK" > #if (supportsMulticore()) types <- c(types, "FORK") > > setupClusterWithoutPkgs <- function(type = "PSOCK", + withs = c("digest", "globals", + "listenv", "future"), + withouts = c("doFuture")) { + cl <- parallel::makeCluster(1L, type = type, timeout = 60) + + ## Emulate a worker that does not have 'future' installed. + ## by setting a different user library path on the worker. + libs <- parallel::clusterEvalQ(cl, .libPaths(tempdir()))[[1]] + attr(cl, "libs") <- libs + + ## 'withouts' tops 'withs' for conveniency + withs <- setdiff(withs, withouts) + + ## "Install" any 'withs' packages? + if (length(withs) > 0L) { + paths <- find.package(withs) + res <- parallel::clusterCall(cl, fun = sapply, X = paths, + FUN = file.copy, to = libs[1], + recursive = TRUE)[[1]] + res <- parallel::clusterCall(cl, fun = sapply, X = withs, + FUN = requireNamespace)[[1]] + } + attr(cl, "withs") <- res + + ## Check whether 'future' is still available on the worker or not. + ## It could be that it is installed in the system library path, which + ## in case we cannot "hide" the future package from the worker. + res <- parallel::clusterCall(cl, fun = sapply, X = withouts, + FUN = requireNamespace)[[1]] + attr(cl, "withouts") <- res + + cl + } > > cl <- NULL > for (type in types) { + message(sprintf("Test set #1 with cluster type %s ...", sQuote(type))) + + cl <- setupClusterWithoutPkgs(type, withouts = c("future", "doFuture")) + if (all(attr(cl, "withs")) && !all(attr(cl, "withouts"))) { + plan(cluster, workers = cl, .init = FALSE) + + ## Here we will get: + ## + ## Note: This error is produced by the future backend when it recieves + ## the unexpected results. + res <- tryCatch({ + y <- foreach(ii = 1:3) %dofuture% ii + }, error = identity) + print(res) + stopifnot(inherits(res, "FutureError")) + } + parallel::stopCluster(cl) + cl <- NULL + + cl <- setupClusterWithoutPkgs(type) + if (all(attr(cl, "withs")) && !all(attr(cl, "withouts"))) { + plan(cluster, workers = cl, .init = FALSE) + + ## Here we will get: + ## + ## Note: This error is produced by the future backend when it recieves + ## the unexpected results. + res <- tryCatch({ + y <- foreach(ii = 1:3) %dofuture% ii + }, error = identity) + print(res) + stopifnot(inherits(res, "FutureError")) + } + parallel::stopCluster(cl) + cl <- NULL + + plan(sequential) + + message(sprintf("Test set #1 with cluster type %s ... DONE", sQuote(type))) + } ## for (type ...) Test set #1 with cluster type 'PSOCK' ... [05:58:35.402] doFuture2() ... [05:58:35.457] Number of chunks: 1 [05:58:35.458] Number of futures (= number of chunks): 1 [05:58:35.458] seed = FALSE [05:58:35.459] NULL [05:58:35.462] seed = FALSE [05:58:35.462] seed = FALSE [05:58:35.463] - %dofuture% R expression: [05:58:35.463] ii [05:58:35.463] - foreach iterator arguments: [1] 'ii' [05:58:35.464] - dummy globals (as locals): [1] 'ii' [05:58:35.464] - R expression (map-reduce expression adjusted for RNG): [05:58:35.465] { [05:58:35.465] NULL [05:58:35.465] "# doFuture():::doFuture2(): process chunk of elements" [05:58:35.465] lapply(seq_along(...future.x_ii), FUN = function(jj) { [05:58:35.465] ...future.x_jj <- ...future.x_ii[[jj]] [05:58:35.465] { [05:58:35.465] NULL [05:58:35.465] ii <- NULL [05:58:35.465] } [05:58:35.465] ...future.env <- environment() [05:58:35.465] local({ [05:58:35.465] for (name in names(...future.x_jj)) { [05:58:35.465] assign(name, ...future.x_jj[[name]], envir = ...future.env, [05:58:35.465] inherits = FALSE) [05:58:35.465] } [05:58:35.465] }) [05:58:35.465] NULL [05:58:35.465] tryCatch(ii, error = identity) [05:58:35.465] }) [05:58:35.465] } [05:58:35.465] - identifying globals and packages ... [05:58:35.465] - Argument 'globals': [05:58:35.465] logi TRUE [05:58:35.465] - attr(*, "add")= chr "...future.x_ii" [05:58:35.465] - attr(*, "ignore")= chr "ii" [05:58:35.468] - R expression (map-reduce expression searched for globals): [05:58:35.468] { [05:58:35.468] NULL [05:58:35.468] "# doFuture():::doFuture2(): process chunk of elements" [05:58:35.468] lapply(seq_along(...future.x_ii), FUN = function(jj) { [05:58:35.468] ...future.x_jj <- ...future.x_ii[[jj]] [05:58:35.468] { [05:58:35.468] NULL [05:58:35.468] ii <- NULL [05:58:35.468] } [05:58:35.468] ...future.env <- environment() [05:58:35.468] local({ [05:58:35.468] for (name in names(...future.x_jj)) { [05:58:35.468] assign(name, ...future.x_jj[[name]], envir = ...future.env, [05:58:35.468] inherits = FALSE) [05:58:35.468] } [05:58:35.468] }) [05:58:35.468] NULL [05:58:35.468] tryCatch(ii, error = identity) [05:58:35.468] }) [05:58:35.468] } [05:58:35.479] - R expression (%dofuture% expression searched for globals): [05:58:35.479] ii [05:58:35.480] - Globals in %dofuture% R expression not in map-reduce expression: [05:58:35.480] - Appending 0 globals only found in the vanilla %dofuture% expression: [05:58:35.481] - globals: [1] '...future.x_ii' [05:58:35.481] List of 1 [05:58:35.481] $ ...future.x_ii: num 42 [05:58:35.481] - attr(*, "where")=List of 1 [05:58:35.481] ..$ ...future.x_ii: [05:58:35.481] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [05:58:35.481] - attr(*, "resolved")= logi FALSE [05:58:35.481] - attr(*, "total_size")= num 39 [05:58:35.485] - packages: [1] 'doFuture' [05:58:35.486] - identifying globals and packages ... DONE [05:58:35.486] Launching 1 futures (chunks) ... [05:58:35.486] Chunk #1 of 1 ... [05:58:35.487] - Finding globals in 'args_list' for chunk #1 ... [05:58:35.488] [05:58:35.488] [05:58:35.489] - Finding globals in 'args_list' for chunk #1 ... DONE [05:58:35.489] - seeds: [05:58:35.498] Chunk #1 of 1 ... DONE [05:58:35.498] Launching 1 futures (chunks) ... DONE [05:58:35.499] - resolving futures [05:58:35.499] - gathering results & relaying conditions (except errors) Future UUID: e608a6df73248bb4fdaf2045a8a2a259-2 DEBUG: BEGIN TROUBLESHOOTING HELP Future involved: ClusterFuture: Label: 'doFuture2-1' Expression: { NULL "# doFuture():::doFuture2(): process chunk of elements" lapply(seq_along(...future.x_ii), FUN = function(jj) { ...future.x_jj <- ...future.x_ii[[jj]] { NULL ii <- NULL } ...future.env <- environment() local({ for (name in names(...future.x_jj)) { assign(name, ...future.x_jj[[name]], envir = ...future.env, inherits = FALSE) } }) NULL tryCatch(ii, error = identity) }) } Lazy evaluation: FALSE Asynchronous evaluation: TRUE Local evaluation: TRUE Environment: R_GlobalEnv Capture standard output: TRUE Capture condition classes: 'condition' (excluding '') Immediate condition classes: 'immediateCondition' Globals: 1 objects totaling 194 bytes (list '...future.x_ii' of 194 bytes) Packages: 1 packages ('doFuture') L'Ecuyer-CMRG RNG seed: (seed = FALSE) Resolved: TRUE Value: Conditions captured: Early signaling: FALSE Owner process: e608a6df73248bb4fdaf2045a8a2a259 Class: 'ClusterFuture', 'MultiprocessFuture', 'Future' DEBUG: END TROUBLESHOOTING HELP Error in serialize(data, node$con) : error writing to connection Calls: ... postNode -> sendData -> sendData.SOCKnode -> serialize Execution halted Running the tests in 'tests/foreach_dopar,cluster-missing-doFuture-pkg.R' failed. Complete output: > source("incl/start.R") Loading required package: foreach Loading required package: future R Under development (unstable) (2025-04-16 r88149 ucrt) Platform: x86_64-w64-mingw32/x64 Running under: Windows Server 2022 x64 (build 20348) Matrix products: default LAPACK version 3.12.1 locale: [1] LC_COLLATE=C LC_CTYPE=German_Germany.utf8 [3] LC_MONETARY=C LC_NUMERIC=C [5] LC_TIME=C time zone: Europe/Berlin tzcode source: internal attached base packages: [1] stats graphics grDevices utils datasets methods base other attached packages: [1] doFuture_1.0.2 future_1.40.0 foreach_1.5.2 loaded via a namespace (and not attached): [1] compiler_4.6.0 parallelly_1.43.0 tools_4.6.0 [4] parallel_4.6.0 future.apply_1.11.3 listenv_0.9.1 [7] codetools_0.2-20 iterators_1.0.14 digest_0.6.37 [10] globals_0.17.0 > options(future.debug = FALSE) > > message("*** cluster() ...") *** cluster() ... > > registerDoFuture() > > message("Library paths: ", paste(sQuote(.libPaths()), collapse = ", ")) Library paths: 'D:/temp/2025_04_17_01_50_00_8240/RtmpA5Nt7O/RLIBS_2c6dc3ecf4a04', 'D:/RCompile/recent/R/library' > message("Package path: ", sQuote(system.file(package = "future"))) Package path: 'D:/RCompile/CRANpkg/lib/4.6/future' > > types <- "PSOCK" > #if (supportsMulticore()) types <- c(types, "FORK") > > setupClusterWithoutPkgs <- function(type = "PSOCK", + withs = c("digest", "globals", + "listenv", "future"), + withouts = c("doFuture")) { + cl <- parallel::makeCluster(1L, type = type, timeout = 60) + + ## Emulate a worker that does not have 'future' installed. + ## by setting a different user library path on the worker. + libs <- parallel::clusterEvalQ(cl, .libPaths(tempdir()))[[1]] + attr(cl, "libs") <- libs + + ## 'withouts' tops 'withs' for conveniency + withs <- setdiff(withs, withouts) + + ## "Install" any 'withs' packages? + if (length(withs) > 0L) { + paths <- find.package(withs) + res <- parallel::clusterCall(cl, fun = sapply, X = paths, + FUN = file.copy, to = libs[1], + recursive = TRUE)[[1]] + res <- parallel::clusterCall(cl, fun = sapply, X = withs, + FUN = requireNamespace)[[1]] + } + attr(cl, "withs") <- res + + ## Check whether 'future' is still available on the worker or not. + ## It could be that it is installed in the system library path, which + ## in case we cannot "hide" the future package from the worker. + res <- parallel::clusterCall(cl, fun = sapply, X = withouts, + FUN = requireNamespace)[[1]] + attr(cl, "withouts") <- res + + cl + } > > > cl <- NULL > for (type in types) { + message(sprintf("Test set #1 with cluster type %s ...", sQuote(type))) + + cl <- setupClusterWithoutPkgs(type, withouts = c("future", "doFuture")) + if (all(attr(cl, "withs")) && !all(attr(cl, "withouts"))) { + plan(cluster, workers = cl, .init = FALSE) + + ## Here we will get: + ## + ## Note: This error is produced by the future backend when it recieves + ## the unexpected results. + res <- tryCatch({ + y <- foreach(ii = 1:3) %dopar% ii + }, error = identity) + print(res) + stopifnot(inherits(res, "FutureError")) + } + parallel::stopCluster(cl) + cl <- NULL + + cl <- setupClusterWithoutPkgs(type) + if (all(attr(cl, "withs")) && !all(attr(cl, "withouts"))) { + plan(cluster, workers = cl, .init = FALSE) + + ## Here we will get: + ## + ## Note: This error is produced by the future backend when it recieves + ## the unexpected results. + res <- tryCatch({ + y <- foreach(ii = 1:3) %dopar% ii + }, error = identity) + print(res) + stopifnot(inherits(res, "FutureError")) + } + parallel::stopCluster(cl) + cl <- NULL + + plan(sequential) + + message(sprintf("Test set #1 with cluster type %s ... DONE", sQuote(type))) + } ## for (type ...) Test set #1 with cluster type 'PSOCK' ... [06:00:31.863] doFuture() ... [06:00:31.866] - dummy globals (as locals): [1] 'ii' [06:00:31.866] - R expression: [06:00:31.866] { [06:00:31.866] "# doFuture():::doFuture(): Make sure that foreach uses 'doFuture'" [06:00:31.866] "# also in nested calls " [06:00:31.866] doFuture::registerDoFuture() [06:00:31.866] "# doFuture():::doFuture(): process chunk of elements" [06:00:31.866] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:00:31.866] ...future.x_jj <- ...future.x_ii[[jj]] [06:00:31.866] { [06:00:31.866] NULL [06:00:31.866] ii <- NULL [06:00:31.866] } [06:00:31.866] ...future.env <- environment() [06:00:31.866] local({ [06:00:31.866] for (name in names(...future.x_jj)) { [06:00:31.866] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:00:31.866] inherits = FALSE) [06:00:31.866] } [06:00:31.866] }) [06:00:31.866] tryCatch(ii, error = identity) [06:00:31.866] }) [06:00:31.866] } [06:00:31.867] - identifying globals and packages ... [06:00:31.882] List of 1 [06:00:31.882] $ ...future.x_ii: NULL [06:00:31.882] - attr(*, "where")=List of 1 [06:00:31.882] ..$ ...future.x_ii: [06:00:31.882] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:00:31.882] - attr(*, "resolved")= logi FALSE [06:00:31.882] - attr(*, "total_size")= num 27 [06:00:31.892] - R expression: [06:00:31.892] { [06:00:31.892] "# doFuture():::doFuture(): Make sure that foreach uses 'doFuture'" [06:00:31.892] "# also in nested calls " [06:00:31.892] doFuture::registerDoFuture() [06:00:31.892] "# doFuture():::doFuture(): process chunk of elements" [06:00:31.892] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:00:31.892] ...future.x_jj <- ...future.x_ii[[jj]] [06:00:31.892] { [06:00:31.892] NULL [06:00:31.892] ii <- NULL [06:00:31.892] } [06:00:31.892] ...future.env <- environment() [06:00:31.892] local({ [06:00:31.892] for (name in names(...future.x_jj)) { [06:00:31.892] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:00:31.892] inherits = FALSE) [06:00:31.892] } [06:00:31.892] }) [06:00:31.892] tryCatch(ii, error = identity) [06:00:31.892] }) [06:00:31.892] } [06:00:31.893] - globals: [1] '...future.x_ii' [06:00:31.893] List of 1 [06:00:31.893] $ ...future.x_ii: NULL [06:00:31.893] - attr(*, "where")=List of 1 [06:00:31.893] ..$ ...future.x_ii: [06:00:31.893] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:00:31.893] - attr(*, "resolved")= logi FALSE [06:00:31.893] - attr(*, "total_size")= num 27 [06:00:31.898] - packages: [1] 'doFuture' [06:00:31.898] - identifying globals and packages ... DONE [06:00:31.951] Number of chunks: 1 [06:00:31.952] Number of futures (= number of chunks): 1 [06:00:31.952] Launching 1 futures (chunks) ... [06:00:31.952] Chunk #1 of 1 ... [06:00:31.952] - Finding globals in 'args_list' chunk #1 ... [06:00:31.953] [06:00:31.954] [06:00:31.954] - Finding globals in 'args_list' for chunk #1 ... DONE [06:00:31.961] Chunk #1 of 1 ... DONE [06:00:31.961] Launching 1 futures (chunks) ... DONE [06:00:31.961] - resolving futures [06:00:31.962] - gathering results & relaying conditions (except errors) Future UUID: a62247df224483150ce2e803eb1accfe-2 DEBUG: BEGIN TROUBLESHOOTING HELP Future involved: ClusterFuture: Label: 'doFuture-1' Expression: { "# doFuture():::doFuture(): Make sure that foreach uses 'doFuture'" "# also in nested calls " doFuture::registerDoFuture() "# doFuture():::doFuture(): process chunk of elements" lapply(seq_along(...future.x_ii), FUN = function(jj) { ...future.x_jj <- ...future.x_ii[[jj]] { NULL ii <- NULL } ...future.env <- environment() local({ for (name in names(...future.x_jj)) { assign(name, ...future.x_jj[[name]], envir = ...future.env, inherits = FALSE) } }) tryCatch(ii, error = identity) }) } Lazy evaluation: FALSE Asynchronous evaluation: TRUE Local evaluation: TRUE Environment: R_GlobalEnv Capture standard output: TRUE Capture condition classes: 'condition' (excluding '') Immediate condition classes: 'immediateCondition' Globals: 1 objects totaling 194 bytes (list '...future.x_ii' of 194 bytes) Packages: 1 packages ('doFuture') L'Ecuyer-CMRG RNG seed: (seed = FALSE) Resolved: TRUE Value: Conditions captured: Early signaling: FALSE Owner process: a62247df224483150ce2e803eb1accfe Class: 'ClusterFuture', 'MultiprocessFuture', 'Future' DEBUG: END TROUBLESHOOTING HELP Error in serialize(data, node$con) : error writing to connection Calls: ... postNode -> sendData -> sendData.SOCKnode -> serialize Execution halted * checking for unstated dependencies in vignettes ... OK * checking package vignettes ... OK * checking re-building of vignette outputs ... [4s] OK * checking PDF version of manual ... [21s] OK * checking HTML version of manual ... [2s] OK * DONE Status: 1 ERROR