R version 4.5.0 alpha (2025-03-15 r87978 ucrt) 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. > source("incl/start.R") Loading required package: foreach Loading required package: future R version 4.5.0 alpha (2025-03-15 r87978 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.34.0 foreach_1.5.2 loaded via a namespace (and not attached): [1] compiler_4.5.0 parallelly_1.42.0 tools_4.5.0 [4] parallel_4.5.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.16.3 > > message("*** Options in nested parallelization ...") *** Options in nested parallelization ... > > options(future.debug = FALSE) > options(future.apply.debug = FALSE) > options(future.globals.maxSize = 1234000) > > for (cores in 1:availCores) { + message(sprintf("Testing with %d cores ...", cores)) + options(mc.cores = cores) + strategies <- supportedStrategies(cores) + + for (strategy1 in strategies) { + for (strategy2 in strategies) { + message(sprintf("- plan('%s') ...", strategy2)) + plan(list(outer = tweak(strategy1), inner = strategy2)) + + v <- foreach(x = 1:2) %dofuture% { + outer <- data.frame( + label = "outer", + idx = x, + pid = Sys.getpid(), + maxSize = getOption("future.globals.maxSize", NA_real_) + ) + + inner <- foreach(x = 3:4) %dofuture% { + data.frame( + label = "inner", + idx = x, + pid = Sys.getpid(), + maxSize = getOption("future.globals.maxSize", NA_real_)) + } + inner <- do.call(rbind, inner) + rbind(outer, inner) + } + v <- do.call(rbind, v) + print(v) + stopifnot(!anyNA(v$maxSize)) + } ## for (strategy2 ...) + } ## for (strategy1 ...) + } ## for (cores in ...) Testing with 1 cores ... - plan('sequential') ... [06:32:56.982] doFuture2() ... [06:32:56.985] Number of chunks: 1 [06:32:56.985] Number of futures (= number of chunks): 1 [06:32:56.985] seed = FALSE [06:32:56.986] NULL [06:32:56.989] seed = FALSE [06:32:56.989] seed = FALSE [06:32:56.989] - %dofuture% R expression: [06:32:56.989] { [06:32:56.989] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:56.989] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:56.989] inner <- foreach(x = 3:4) %dofuture% { [06:32:56.989] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:56.989] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:56.989] } [06:32:56.989] inner <- do.call(rbind, inner) [06:32:56.989] rbind(outer, inner) [06:32:56.989] } [06:32:56.990] - foreach iterator arguments: [1] 'x' [06:32:56.990] - dummy globals (as locals): [1] 'x' [06:32:56.990] - R expression (map-reduce expression adjusted for RNG): [06:32:56.991] { [06:32:56.991] NULL [06:32:56.991] "# doFuture():::doFuture2(): process chunk of elements" [06:32:56.991] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:56.991] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:56.991] { [06:32:56.991] NULL [06:32:56.991] x <- NULL [06:32:56.991] } [06:32:56.991] ...future.env <- environment() [06:32:56.991] local({ [06:32:56.991] for (name in names(...future.x_jj)) { [06:32:56.991] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:56.991] inherits = FALSE) [06:32:56.991] } [06:32:56.991] }) [06:32:56.991] NULL [06:32:56.991] tryCatch({ [06:32:56.991] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:56.991] maxSize = getOption("future.globals.maxSize", [06:32:56.991] NA_real_)) [06:32:56.991] inner <- foreach(x = 3:4) %dofuture% { [06:32:56.991] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:56.991] maxSize = getOption("future.globals.maxSize", [06:32:56.991] NA_real_)) [06:32:56.991] } [06:32:56.991] inner <- do.call(rbind, inner) [06:32:56.991] rbind(outer, inner) [06:32:56.991] }, error = identity) [06:32:56.991] }) [06:32:56.991] } [06:32:56.991] - identifying globals and packages ... [06:32:56.992] - Argument 'globals': [06:32:56.992] logi TRUE [06:32:56.992] - attr(*, "add")= chr "...future.x_ii" [06:32:56.992] - attr(*, "ignore")= chr "x" [06:32:56.994] - R expression (map-reduce expression searched for globals): [06:32:56.994] { [06:32:56.994] NULL [06:32:56.994] "# doFuture():::doFuture2(): process chunk of elements" [06:32:56.994] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:56.994] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:56.994] { [06:32:56.994] NULL [06:32:56.994] x <- NULL [06:32:56.994] } [06:32:56.994] ...future.env <- environment() [06:32:56.994] local({ [06:32:56.994] for (name in names(...future.x_jj)) { [06:32:56.994] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:56.994] inherits = FALSE) [06:32:56.994] } [06:32:56.994] }) [06:32:56.994] NULL [06:32:56.994] tryCatch({ [06:32:56.994] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:56.994] maxSize = getOption("future.globals.maxSize", [06:32:56.994] NA_real_)) [06:32:56.994] inner <- foreach(x = 3:4) %dofuture% { [06:32:56.994] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:56.994] maxSize = getOption("future.globals.maxSize", [06:32:56.994] NA_real_)) [06:32:56.994] } [06:32:56.994] inner <- do.call(rbind, inner) [06:32:56.994] rbind(outer, inner) [06:32:56.994] }, error = identity) [06:32:56.994] }) [06:32:56.994] } [06:32:57.027] - globals: [1] '...future.x_ii' [06:32:57.027] List of 1 [06:32:57.027] $ ...future.x_ii: num 42 [06:32:57.027] - attr(*, "where")=List of 1 [06:32:57.027] ..$ ...future.x_ii: [06:32:57.027] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.027] - attr(*, "resolved")= logi FALSE [06:32:57.027] - attr(*, "total_size")= num 39 [06:32:57.038] - packages: [2] 'doFuture', 'foreach' [06:32:57.038] - identifying globals and packages ... DONE [06:32:57.038] Launching 1 futures (chunks) ... [06:32:57.039] Chunk #1 of 1 ... [06:32:57.039] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.040] [06:32:57.040] [06:32:57.041] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.041] - seeds: [06:32:57.216] Chunk #1 of 1 ... DONE [06:32:57.217] Launching 1 futures (chunks) ... DONE [06:32:57.217] - resolving futures [06:32:57.217] - gathering results & relaying conditions (except errors) [06:32:57.047] doFuture2() ... [06:32:57.048] Number of chunks: 1 [06:32:57.076] Number of futures (= number of chunks): 1 [06:32:57.077] seed = FALSE [06:32:57.077] NULL [06:32:57.078] seed = FALSE [06:32:57.078] seed = FALSE [06:32:57.079] - %dofuture% R expression: [06:32:57.079] { [06:32:57.079] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.079] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.079] } [06:32:57.079] - foreach iterator arguments: [1] 'x' [06:32:57.080] - dummy globals (as locals): [1] 'x' [06:32:57.080] - R expression (map-reduce expression adjusted for RNG): [06:32:57.080] { [06:32:57.080] NULL [06:32:57.080] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.080] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.080] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.080] { [06:32:57.080] NULL [06:32:57.080] x <- NULL [06:32:57.080] } [06:32:57.080] ...future.env <- environment() [06:32:57.080] local({ [06:32:57.080] for (name in names(...future.x_jj)) { [06:32:57.080] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.080] inherits = FALSE) [06:32:57.080] } [06:32:57.080] }) [06:32:57.080] NULL [06:32:57.080] tryCatch({ [06:32:57.080] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.080] maxSize = getOption("future.globals.maxSize", [06:32:57.080] NA_real_)) [06:32:57.080] }, error = identity) [06:32:57.080] }) [06:32:57.080] } [06:32:57.081] - identifying globals and packages ... [06:32:57.082] - Argument 'globals': [06:32:57.082] logi TRUE [06:32:57.082] - attr(*, "add")= chr "...future.x_ii" [06:32:57.082] - attr(*, "ignore")= chr "x" [06:32:57.084] - R expression (map-reduce expression searched for globals): [06:32:57.084] { [06:32:57.084] NULL [06:32:57.084] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.084] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.084] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.084] { [06:32:57.084] NULL [06:32:57.084] x <- NULL [06:32:57.084] } [06:32:57.084] ...future.env <- environment() [06:32:57.084] local({ [06:32:57.084] for (name in names(...future.x_jj)) { [06:32:57.084] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.084] inherits = FALSE) [06:32:57.084] } [06:32:57.084] }) [06:32:57.084] NULL [06:32:57.084] tryCatch({ [06:32:57.084] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.084] maxSize = getOption("future.globals.maxSize", [06:32:57.084] NA_real_)) [06:32:57.084] }, error = identity) [06:32:57.084] }) [06:32:57.084] } [06:32:57.097] - globals: [1] '...future.x_ii' [06:32:57.097] List of 1 [06:32:57.097] $ ...future.x_ii: num 42 [06:32:57.097] - attr(*, "where")=List of 1 [06:32:57.097] ..$ ...future.x_ii: [06:32:57.097] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.097] - attr(*, "resolved")= logi FALSE [06:32:57.097] - attr(*, "total_size")= num 39 [06:32:57.100] - packages: [1] 'doFuture' [06:32:57.100] - identifying globals and packages ... DONE [06:32:57.100] Launching 1 futures (chunks) ... [06:32:57.101] Chunk #1 of 1 ... [06:32:57.101] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.101] [06:32:57.101] [06:32:57.102] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.102] - seeds: [06:32:57.116] Chunk #1 of 1 ... DONE [06:32:57.116] Launching 1 futures (chunks) ... DONE [06:32:57.116] - resolving futures [06:32:57.116] - gathering results & relaying conditions (except errors) [06:32:57.118] - Number of value chunks collected: 1 [06:32:57.118] Resolving 1 futures (chunks) ... DONE [06:32:57.118] Reducing values from 1 chunks ... [06:32:57.118] Raw results: [06:32:57.118] List of 1 [06:32:57.118] $ :List of 2 [06:32:57.118] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.118] .. ..$ label : chr "inner" [06:32:57.118] .. ..$ idx : int 3 [06:32:57.118] .. ..$ pid : int 43768 [06:32:57.118] .. ..$ maxSize: num 1234000 [06:32:57.118] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.118] .. ..$ label : chr "inner" [06:32:57.118] .. ..$ idx : int 4 [06:32:57.118] .. ..$ pid : int 43768 [06:32:57.118] .. ..$ maxSize: num 1234000 [06:32:57.127] Combined results: [06:32:57.127] List of 2 [06:32:57.127] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.127] ..$ label : chr "inner" [06:32:57.127] ..$ idx : int 3 [06:32:57.127] ..$ pid : int 43768 [06:32:57.127] ..$ maxSize: num 1234000 [06:32:57.127] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.127] ..$ label : chr "inner" [06:32:57.127] ..$ idx : int 4 [06:32:57.127] ..$ pid : int 43768 [06:32:57.127] ..$ maxSize: num 1234000 [06:32:57.134] - accumulating results [06:32:57.136] - extracting results [06:32:57.136] doFuture2() ... DONE [06:32:57.155] doFuture2() ... [06:32:57.157] Number of chunks: 1 [06:32:57.157] Number of futures (= number of chunks): 1 [06:32:57.157] seed = FALSE [06:32:57.158] NULL [06:32:57.158] seed = FALSE [06:32:57.159] seed = FALSE [06:32:57.159] - %dofuture% R expression: [06:32:57.159] { [06:32:57.159] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.159] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.159] } [06:32:57.160] - foreach iterator arguments: [1] 'x' [06:32:57.160] - dummy globals (as locals): [1] 'x' [06:32:57.161] - R expression (map-reduce expression adjusted for RNG): [06:32:57.161] { [06:32:57.161] NULL [06:32:57.161] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.161] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.161] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.161] { [06:32:57.161] NULL [06:32:57.161] x <- NULL [06:32:57.161] } [06:32:57.161] ...future.env <- environment() [06:32:57.161] local({ [06:32:57.161] for (name in names(...future.x_jj)) { [06:32:57.161] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.161] inherits = FALSE) [06:32:57.161] } [06:32:57.161] }) [06:32:57.161] NULL [06:32:57.161] tryCatch({ [06:32:57.161] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.161] maxSize = getOption("future.globals.maxSize", [06:32:57.161] NA_real_)) [06:32:57.161] }, error = identity) [06:32:57.161] }) [06:32:57.161] } [06:32:57.162] - identifying globals and packages ... [06:32:57.162] - Argument 'globals': [06:32:57.162] logi TRUE [06:32:57.162] - attr(*, "add")= chr "...future.x_ii" [06:32:57.162] - attr(*, "ignore")= chr "x" [06:32:57.164] - R expression (map-reduce expression searched for globals): [06:32:57.165] { [06:32:57.165] NULL [06:32:57.165] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.165] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.165] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.165] { [06:32:57.165] NULL [06:32:57.165] x <- NULL [06:32:57.165] } [06:32:57.165] ...future.env <- environment() [06:32:57.165] local({ [06:32:57.165] for (name in names(...future.x_jj)) { [06:32:57.165] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.165] inherits = FALSE) [06:32:57.165] } [06:32:57.165] }) [06:32:57.165] NULL [06:32:57.165] tryCatch({ [06:32:57.165] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.165] maxSize = getOption("future.globals.maxSize", [06:32:57.165] NA_real_)) [06:32:57.165] }, error = identity) [06:32:57.165] }) [06:32:57.165] } [06:32:57.179] - globals: [1] '...future.x_ii' [06:32:57.179] List of 1 [06:32:57.179] $ ...future.x_ii: num 42 [06:32:57.179] - attr(*, "where")=List of 1 [06:32:57.179] ..$ ...future.x_ii: [06:32:57.179] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.179] - attr(*, "resolved")= logi FALSE [06:32:57.179] - attr(*, "total_size")= num 39 [06:32:57.184] - packages: [1] 'doFuture' [06:32:57.184] - identifying globals and packages ... DONE [06:32:57.185] Launching 1 futures (chunks) ... [06:32:57.185] Chunk #1 of 1 ... [06:32:57.185] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.186] [06:32:57.186] [06:32:57.187] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.187] - seeds: [06:32:57.195] Chunk #1 of 1 ... DONE [06:32:57.195] Launching 1 futures (chunks) ... DONE [06:32:57.195] - resolving futures [06:32:57.195] - gathering results & relaying conditions (except errors) [06:32:57.196] - Number of value chunks collected: 1 [06:32:57.197] Resolving 1 futures (chunks) ... DONE [06:32:57.197] Reducing values from 1 chunks ... [06:32:57.197] Raw results: [06:32:57.198] List of 1 [06:32:57.198] $ :List of 2 [06:32:57.198] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.198] .. ..$ label : chr "inner" [06:32:57.198] .. ..$ idx : int 3 [06:32:57.198] .. ..$ pid : int 43768 [06:32:57.198] .. ..$ maxSize: num 1234000 [06:32:57.198] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.198] .. ..$ label : chr "inner" [06:32:57.198] .. ..$ idx : int 4 [06:32:57.198] .. ..$ pid : int 43768 [06:32:57.198] .. ..$ maxSize: num 1234000 [06:32:57.205] Combined results: [06:32:57.205] List of 2 [06:32:57.205] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.205] ..$ label : chr "inner" [06:32:57.205] ..$ idx : int 3 [06:32:57.205] ..$ pid : int 43768 [06:32:57.205] ..$ maxSize: num 1234000 [06:32:57.205] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.205] ..$ label : chr "inner" [06:32:57.205] ..$ idx : int 4 [06:32:57.205] ..$ pid : int 43768 [06:32:57.205] ..$ maxSize: num 1234000 [06:32:57.212] - accumulating results [06:32:57.213] - extracting results [06:32:57.213] doFuture2() ... DONE [06:32:57.230] - Number of value chunks collected: 1 [06:32:57.231] Resolving 1 futures (chunks) ... DONE [06:32:57.231] Reducing values from 1 chunks ... [06:32:57.231] Raw results: [06:32:57.232] List of 1 [06:32:57.232] $ :List of 2 [06:32:57.232] ..$ :'data.frame': 3 obs. of 4 variables: [06:32:57.232] .. ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.232] .. ..$ idx : int [1:3] 1 3 4 [06:32:57.232] .. ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.232] .. ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.232] ..$ :'data.frame': 3 obs. of 4 variables: [06:32:57.232] .. ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.232] .. ..$ idx : int [1:3] 2 3 4 [06:32:57.232] .. ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.232] .. ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.240] Combined results: [06:32:57.240] List of 2 [06:32:57.240] $ :'data.frame': 3 obs. of 4 variables: [06:32:57.240] ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.240] ..$ idx : int [1:3] 1 3 4 [06:32:57.240] ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.240] ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.240] $ :'data.frame': 3 obs. of 4 variables: [06:32:57.240] ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.240] ..$ idx : int [1:3] 2 3 4 [06:32:57.240] ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.240] ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.246] - accumulating results [06:32:57.247] - extracting results [06:32:57.247] doFuture2() ... DONE label idx pid maxSize 1 outer 1 43768 1234000 2 inner 3 43768 1234000 3 inner 4 43768 1234000 4 outer 2 43768 1234000 5 inner 3 43768 1234000 6 inner 4 43768 1234000 - plan('multisession') ... [06:32:57.250] doFuture2() ... [06:32:57.251] Number of chunks: 1 [06:32:57.251] Number of futures (= number of chunks): 1 [06:32:57.252] seed = FALSE [06:32:57.252] NULL [06:32:57.252] seed = FALSE [06:32:57.252] seed = FALSE [06:32:57.253] - %dofuture% R expression: [06:32:57.253] { [06:32:57.253] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:57.253] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.253] inner <- foreach(x = 3:4) %dofuture% { [06:32:57.253] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.253] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.253] } [06:32:57.253] inner <- do.call(rbind, inner) [06:32:57.253] rbind(outer, inner) [06:32:57.253] } [06:32:57.253] - foreach iterator arguments: [1] 'x' [06:32:57.254] - dummy globals (as locals): [1] 'x' [06:32:57.254] - R expression (map-reduce expression adjusted for RNG): [06:32:57.254] { [06:32:57.254] NULL [06:32:57.254] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.254] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.254] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.254] { [06:32:57.254] NULL [06:32:57.254] x <- NULL [06:32:57.254] } [06:32:57.254] ...future.env <- environment() [06:32:57.254] local({ [06:32:57.254] for (name in names(...future.x_jj)) { [06:32:57.254] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.254] inherits = FALSE) [06:32:57.254] } [06:32:57.254] }) [06:32:57.254] NULL [06:32:57.254] tryCatch({ [06:32:57.254] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:57.254] maxSize = getOption("future.globals.maxSize", [06:32:57.254] NA_real_)) [06:32:57.254] inner <- foreach(x = 3:4) %dofuture% { [06:32:57.254] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.254] maxSize = getOption("future.globals.maxSize", [06:32:57.254] NA_real_)) [06:32:57.254] } [06:32:57.254] inner <- do.call(rbind, inner) [06:32:57.254] rbind(outer, inner) [06:32:57.254] }, error = identity) [06:32:57.254] }) [06:32:57.254] } [06:32:57.255] - identifying globals and packages ... [06:32:57.256] - Argument 'globals': [06:32:57.256] logi TRUE [06:32:57.256] - attr(*, "add")= chr "...future.x_ii" [06:32:57.256] - attr(*, "ignore")= chr "x" [06:32:57.258] - R expression (map-reduce expression searched for globals): [06:32:57.258] { [06:32:57.258] NULL [06:32:57.258] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.258] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.258] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.258] { [06:32:57.258] NULL [06:32:57.258] x <- NULL [06:32:57.258] } [06:32:57.258] ...future.env <- environment() [06:32:57.258] local({ [06:32:57.258] for (name in names(...future.x_jj)) { [06:32:57.258] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.258] inherits = FALSE) [06:32:57.258] } [06:32:57.258] }) [06:32:57.258] NULL [06:32:57.258] tryCatch({ [06:32:57.258] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:57.258] maxSize = getOption("future.globals.maxSize", [06:32:57.258] NA_real_)) [06:32:57.258] inner <- foreach(x = 3:4) %dofuture% { [06:32:57.258] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.258] maxSize = getOption("future.globals.maxSize", [06:32:57.258] NA_real_)) [06:32:57.258] } [06:32:57.258] inner <- do.call(rbind, inner) [06:32:57.258] rbind(outer, inner) [06:32:57.258] }, error = identity) [06:32:57.258] }) [06:32:57.258] } [06:32:57.277] - globals: [1] '...future.x_ii' [06:32:57.278] List of 1 [06:32:57.278] $ ...future.x_ii: num 42 [06:32:57.278] - attr(*, "where")=List of 1 [06:32:57.278] ..$ ...future.x_ii: [06:32:57.278] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.278] - attr(*, "resolved")= logi FALSE [06:32:57.278] - attr(*, "total_size")= num 39 [06:32:57.283] - packages: [2] 'doFuture', 'foreach' [06:32:57.284] - identifying globals and packages ... DONE [06:32:57.284] Launching 1 futures (chunks) ... [06:32:57.284] Chunk #1 of 1 ... [06:32:57.285] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.286] [06:32:57.286] [06:32:57.286] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.286] - seeds: [06:32:57.462] Chunk #1 of 1 ... DONE [06:32:57.463] Launching 1 futures (chunks) ... DONE [06:32:57.463] - resolving futures [06:32:57.463] - gathering results & relaying conditions (except errors) [06:32:57.298] doFuture2() ... [06:32:57.304] Number of chunks: 1 [06:32:57.332] Number of futures (= number of chunks): 1 [06:32:57.333] seed = FALSE [06:32:57.333] NULL [06:32:57.334] seed = FALSE [06:32:57.334] seed = FALSE [06:32:57.334] - %dofuture% R expression: [06:32:57.335] { [06:32:57.335] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.335] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.335] } [06:32:57.335] - foreach iterator arguments: [1] 'x' [06:32:57.335] - dummy globals (as locals): [1] 'x' [06:32:57.336] - R expression (map-reduce expression adjusted for RNG): [06:32:57.336] { [06:32:57.336] NULL [06:32:57.336] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.336] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.336] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.336] { [06:32:57.336] NULL [06:32:57.336] x <- NULL [06:32:57.336] } [06:32:57.336] ...future.env <- environment() [06:32:57.336] local({ [06:32:57.336] for (name in names(...future.x_jj)) { [06:32:57.336] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.336] inherits = FALSE) [06:32:57.336] } [06:32:57.336] }) [06:32:57.336] NULL [06:32:57.336] tryCatch({ [06:32:57.336] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.336] maxSize = getOption("future.globals.maxSize", [06:32:57.336] NA_real_)) [06:32:57.336] }, error = identity) [06:32:57.336] }) [06:32:57.336] } [06:32:57.337] - identifying globals and packages ... [06:32:57.337] - Argument 'globals': [06:32:57.337] logi TRUE [06:32:57.337] - attr(*, "add")= chr "...future.x_ii" [06:32:57.337] - attr(*, "ignore")= chr "x" [06:32:57.339] - R expression (map-reduce expression searched for globals): [06:32:57.339] { [06:32:57.339] NULL [06:32:57.339] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.339] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.339] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.339] { [06:32:57.339] NULL [06:32:57.339] x <- NULL [06:32:57.339] } [06:32:57.339] ...future.env <- environment() [06:32:57.339] local({ [06:32:57.339] for (name in names(...future.x_jj)) { [06:32:57.339] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.339] inherits = FALSE) [06:32:57.339] } [06:32:57.339] }) [06:32:57.339] NULL [06:32:57.339] tryCatch({ [06:32:57.339] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.339] maxSize = getOption("future.globals.maxSize", [06:32:57.339] NA_real_)) [06:32:57.339] }, error = identity) [06:32:57.339] }) [06:32:57.339] } [06:32:57.352] - globals: [1] '...future.x_ii' [06:32:57.352] List of 1 [06:32:57.352] $ ...future.x_ii: num 42 [06:32:57.352] - attr(*, "where")=List of 1 [06:32:57.352] ..$ ...future.x_ii: [06:32:57.352] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.352] - attr(*, "resolved")= logi FALSE [06:32:57.352] - attr(*, "total_size")= num 39 [06:32:57.356] - packages: [1] 'doFuture' [06:32:57.356] - identifying globals and packages ... DONE [06:32:57.357] Launching 1 futures (chunks) ... [06:32:57.357] Chunk #1 of 1 ... [06:32:57.357] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.358] [06:32:57.358] [06:32:57.358] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.359] - seeds: [06:32:57.373] Chunk #1 of 1 ... DONE [06:32:57.374] Launching 1 futures (chunks) ... DONE [06:32:57.374] - resolving futures [06:32:57.374] - gathering results & relaying conditions (except errors) [06:32:57.375] - Number of value chunks collected: 1 [06:32:57.375] Resolving 1 futures (chunks) ... DONE [06:32:57.376] Reducing values from 1 chunks ... [06:32:57.376] Raw results: [06:32:57.376] List of 1 [06:32:57.376] $ :List of 2 [06:32:57.376] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.376] .. ..$ label : chr "inner" [06:32:57.376] .. ..$ idx : int 3 [06:32:57.376] .. ..$ pid : int 43768 [06:32:57.376] .. ..$ maxSize: num 1234000 [06:32:57.376] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.376] .. ..$ label : chr "inner" [06:32:57.376] .. ..$ idx : int 4 [06:32:57.376] .. ..$ pid : int 43768 [06:32:57.376] .. ..$ maxSize: num 1234000 [06:32:57.383] Combined results: [06:32:57.383] List of 2 [06:32:57.383] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.383] ..$ label : chr "inner" [06:32:57.383] ..$ idx : int 3 [06:32:57.383] ..$ pid : int 43768 [06:32:57.383] ..$ maxSize: num 1234000 [06:32:57.383] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.383] ..$ label : chr "inner" [06:32:57.383] ..$ idx : int 4 [06:32:57.383] ..$ pid : int 43768 [06:32:57.383] ..$ maxSize: num 1234000 [06:32:57.389] - accumulating results [06:32:57.389] - extracting results [06:32:57.390] doFuture2() ... DONE [06:32:57.391] doFuture2() ... [06:32:57.396] Number of chunks: 1 [06:32:57.397] Number of futures (= number of chunks): 1 [06:32:57.397] seed = FALSE [06:32:57.397] NULL [06:32:57.398] seed = FALSE [06:32:57.398] seed = FALSE [06:32:57.398] - %dofuture% R expression: [06:32:57.399] { [06:32:57.399] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.399] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.399] } [06:32:57.399] - foreach iterator arguments: [1] 'x' [06:32:57.400] - dummy globals (as locals): [1] 'x' [06:32:57.400] - R expression (map-reduce expression adjusted for RNG): [06:32:57.400] { [06:32:57.400] NULL [06:32:57.400] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.400] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.400] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.400] { [06:32:57.400] NULL [06:32:57.400] x <- NULL [06:32:57.400] } [06:32:57.400] ...future.env <- environment() [06:32:57.400] local({ [06:32:57.400] for (name in names(...future.x_jj)) { [06:32:57.400] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.400] inherits = FALSE) [06:32:57.400] } [06:32:57.400] }) [06:32:57.400] NULL [06:32:57.400] tryCatch({ [06:32:57.400] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.400] maxSize = getOption("future.globals.maxSize", [06:32:57.400] NA_real_)) [06:32:57.400] }, error = identity) [06:32:57.400] }) [06:32:57.400] } [06:32:57.401] - identifying globals and packages ... [06:32:57.401] - Argument 'globals': [06:32:57.401] logi TRUE [06:32:57.401] - attr(*, "add")= chr "...future.x_ii" [06:32:57.401] - attr(*, "ignore")= chr "x" [06:32:57.403] - R expression (map-reduce expression searched for globals): [06:32:57.403] { [06:32:57.403] NULL [06:32:57.403] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.403] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.403] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.403] { [06:32:57.403] NULL [06:32:57.403] x <- NULL [06:32:57.403] } [06:32:57.403] ...future.env <- environment() [06:32:57.403] local({ [06:32:57.403] for (name in names(...future.x_jj)) { [06:32:57.403] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.403] inherits = FALSE) [06:32:57.403] } [06:32:57.403] }) [06:32:57.403] NULL [06:32:57.403] tryCatch({ [06:32:57.403] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.403] maxSize = getOption("future.globals.maxSize", [06:32:57.403] NA_real_)) [06:32:57.403] }, error = identity) [06:32:57.403] }) [06:32:57.403] } [06:32:57.416] - globals: [1] '...future.x_ii' [06:32:57.417] List of 1 [06:32:57.417] $ ...future.x_ii: num 42 [06:32:57.417] - attr(*, "where")=List of 1 [06:32:57.417] ..$ ...future.x_ii: [06:32:57.417] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.417] - attr(*, "resolved")= logi FALSE [06:32:57.417] - attr(*, "total_size")= num 39 [06:32:57.421] - packages: [1] 'doFuture' [06:32:57.421] - identifying globals and packages ... DONE [06:32:57.422] Launching 1 futures (chunks) ... [06:32:57.422] Chunk #1 of 1 ... [06:32:57.422] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.423] [06:32:57.423] [06:32:57.424] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.424] - seeds: [06:32:57.442] Chunk #1 of 1 ... DONE [06:32:57.442] Launching 1 futures (chunks) ... DONE [06:32:57.443] - resolving futures [06:32:57.443] - gathering results & relaying conditions (except errors) [06:32:57.444] - Number of value chunks collected: 1 [06:32:57.444] Resolving 1 futures (chunks) ... DONE [06:32:57.445] Reducing values from 1 chunks ... [06:32:57.445] Raw results: [06:32:57.445] List of 1 [06:32:57.445] $ :List of 2 [06:32:57.445] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.445] .. ..$ label : chr "inner" [06:32:57.445] .. ..$ idx : int 3 [06:32:57.445] .. ..$ pid : int 43768 [06:32:57.445] .. ..$ maxSize: num 1234000 [06:32:57.445] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.445] .. ..$ label : chr "inner" [06:32:57.445] .. ..$ idx : int 4 [06:32:57.445] .. ..$ pid : int 43768 [06:32:57.445] .. ..$ maxSize: num 1234000 [06:32:57.452] Combined results: [06:32:57.453] List of 2 [06:32:57.453] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.453] ..$ label : chr "inner" [06:32:57.453] ..$ idx : int 3 [06:32:57.453] ..$ pid : int 43768 [06:32:57.453] ..$ maxSize: num 1234000 [06:32:57.453] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.453] ..$ label : chr "inner" [06:32:57.453] ..$ idx : int 4 [06:32:57.453] ..$ pid : int 43768 [06:32:57.453] ..$ maxSize: num 1234000 [06:32:57.459] - accumulating results [06:32:57.460] - extracting results [06:32:57.460] doFuture2() ... DONE [06:32:57.472] - Number of value chunks collected: 1 [06:32:57.472] Resolving 1 futures (chunks) ... DONE [06:32:57.472] Reducing values from 1 chunks ... [06:32:57.472] Raw results: [06:32:57.473] List of 1 [06:32:57.473] $ :List of 2 [06:32:57.473] ..$ :'data.frame': 3 obs. of 4 variables: [06:32:57.473] .. ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.473] .. ..$ idx : int [1:3] 1 3 4 [06:32:57.473] .. ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.473] .. ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.473] ..$ :'data.frame': 3 obs. of 4 variables: [06:32:57.473] .. ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.473] .. ..$ idx : int [1:3] 2 3 4 [06:32:57.473] .. ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.473] .. ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.479] Combined results: [06:32:57.480] List of 2 [06:32:57.480] $ :'data.frame': 3 obs. of 4 variables: [06:32:57.480] ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.480] ..$ idx : int [1:3] 1 3 4 [06:32:57.480] ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.480] ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.480] $ :'data.frame': 3 obs. of 4 variables: [06:32:57.480] ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.480] ..$ idx : int [1:3] 2 3 4 [06:32:57.480] ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.480] ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.486] - accumulating results [06:32:57.487] - extracting results [06:32:57.487] doFuture2() ... DONE label idx pid maxSize 1 outer 1 43768 1234000 2 inner 3 43768 1234000 3 inner 4 43768 1234000 4 outer 2 43768 1234000 5 inner 3 43768 1234000 6 inner 4 43768 1234000 - plan('sequential') ... [06:32:57.507] doFuture2() ... [06:32:57.512] Number of chunks: 1 [06:32:57.512] Number of futures (= number of chunks): 1 [06:32:57.512] seed = FALSE [06:32:57.513] NULL [06:32:57.513] seed = FALSE [06:32:57.513] seed = FALSE [06:32:57.514] - %dofuture% R expression: [06:32:57.514] { [06:32:57.514] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:57.514] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.514] inner <- foreach(x = 3:4) %dofuture% { [06:32:57.514] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.514] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.514] } [06:32:57.514] inner <- do.call(rbind, inner) [06:32:57.514] rbind(outer, inner) [06:32:57.514] } [06:32:57.514] - foreach iterator arguments: [1] 'x' [06:32:57.515] - dummy globals (as locals): [1] 'x' [06:32:57.515] - R expression (map-reduce expression adjusted for RNG): [06:32:57.515] { [06:32:57.515] NULL [06:32:57.515] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.515] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.515] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.515] { [06:32:57.515] NULL [06:32:57.515] x <- NULL [06:32:57.515] } [06:32:57.515] ...future.env <- environment() [06:32:57.515] local({ [06:32:57.515] for (name in names(...future.x_jj)) { [06:32:57.515] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.515] inherits = FALSE) [06:32:57.515] } [06:32:57.515] }) [06:32:57.515] NULL [06:32:57.515] tryCatch({ [06:32:57.515] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:57.515] maxSize = getOption("future.globals.maxSize", [06:32:57.515] NA_real_)) [06:32:57.515] inner <- foreach(x = 3:4) %dofuture% { [06:32:57.515] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.515] maxSize = getOption("future.globals.maxSize", [06:32:57.515] NA_real_)) [06:32:57.515] } [06:32:57.515] inner <- do.call(rbind, inner) [06:32:57.515] rbind(outer, inner) [06:32:57.515] }, error = identity) [06:32:57.515] }) [06:32:57.515] } [06:32:57.516] - identifying globals and packages ... [06:32:57.516] - Argument 'globals': [06:32:57.517] logi TRUE [06:32:57.517] - attr(*, "add")= chr "...future.x_ii" [06:32:57.517] - attr(*, "ignore")= chr "x" [06:32:57.519] - R expression (map-reduce expression searched for globals): [06:32:57.519] { [06:32:57.519] NULL [06:32:57.519] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.519] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.519] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.519] { [06:32:57.519] NULL [06:32:57.519] x <- NULL [06:32:57.519] } [06:32:57.519] ...future.env <- environment() [06:32:57.519] local({ [06:32:57.519] for (name in names(...future.x_jj)) { [06:32:57.519] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.519] inherits = FALSE) [06:32:57.519] } [06:32:57.519] }) [06:32:57.519] NULL [06:32:57.519] tryCatch({ [06:32:57.519] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:57.519] maxSize = getOption("future.globals.maxSize", [06:32:57.519] NA_real_)) [06:32:57.519] inner <- foreach(x = 3:4) %dofuture% { [06:32:57.519] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.519] maxSize = getOption("future.globals.maxSize", [06:32:57.519] NA_real_)) [06:32:57.519] } [06:32:57.519] inner <- do.call(rbind, inner) [06:32:57.519] rbind(outer, inner) [06:32:57.519] }, error = identity) [06:32:57.519] }) [06:32:57.519] } [06:32:57.539] - globals: [1] '...future.x_ii' [06:32:57.540] List of 1 [06:32:57.540] $ ...future.x_ii: num 42 [06:32:57.540] - attr(*, "where")=List of 1 [06:32:57.540] ..$ ...future.x_ii: [06:32:57.540] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.540] - attr(*, "resolved")= logi FALSE [06:32:57.540] - attr(*, "total_size")= num 39 [06:32:57.544] - packages: [2] 'doFuture', 'foreach' [06:32:57.544] - identifying globals and packages ... DONE [06:32:57.545] Launching 1 futures (chunks) ... [06:32:57.545] Chunk #1 of 1 ... [06:32:57.545] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.546] [06:32:57.546] [06:32:57.546] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.546] - seeds: [06:32:57.692] Chunk #1 of 1 ... DONE [06:32:57.692] Launching 1 futures (chunks) ... DONE [06:32:57.693] - resolving futures [06:32:57.693] - gathering results & relaying conditions (except errors) [06:32:57.555] doFuture2() ... [06:32:57.557] Number of chunks: 1 [06:32:57.581] Number of futures (= number of chunks): 1 [06:32:57.582] seed = FALSE [06:32:57.582] NULL [06:32:57.583] seed = FALSE [06:32:57.583] seed = FALSE [06:32:57.583] - %dofuture% R expression: [06:32:57.583] { [06:32:57.583] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.583] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.583] } [06:32:57.584] - foreach iterator arguments: [1] 'x' [06:32:57.584] - dummy globals (as locals): [1] 'x' [06:32:57.585] - R expression (map-reduce expression adjusted for RNG): [06:32:57.585] { [06:32:57.585] NULL [06:32:57.585] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.585] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.585] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.585] { [06:32:57.585] NULL [06:32:57.585] x <- NULL [06:32:57.585] } [06:32:57.585] ...future.env <- environment() [06:32:57.585] local({ [06:32:57.585] for (name in names(...future.x_jj)) { [06:32:57.585] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.585] inherits = FALSE) [06:32:57.585] } [06:32:57.585] }) [06:32:57.585] NULL [06:32:57.585] tryCatch({ [06:32:57.585] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.585] maxSize = getOption("future.globals.maxSize", [06:32:57.585] NA_real_)) [06:32:57.585] }, error = identity) [06:32:57.585] }) [06:32:57.585] } [06:32:57.586] - identifying globals and packages ... [06:32:57.586] - Argument 'globals': [06:32:57.586] logi TRUE [06:32:57.586] - attr(*, "add")= chr "...future.x_ii" [06:32:57.586] - attr(*, "ignore")= chr "x" [06:32:57.588] - R expression (map-reduce expression searched for globals): [06:32:57.588] { [06:32:57.588] NULL [06:32:57.588] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.588] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.588] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.588] { [06:32:57.588] NULL [06:32:57.588] x <- NULL [06:32:57.588] } [06:32:57.588] ...future.env <- environment() [06:32:57.588] local({ [06:32:57.588] for (name in names(...future.x_jj)) { [06:32:57.588] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.588] inherits = FALSE) [06:32:57.588] } [06:32:57.588] }) [06:32:57.588] NULL [06:32:57.588] tryCatch({ [06:32:57.588] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.588] maxSize = getOption("future.globals.maxSize", [06:32:57.588] NA_real_)) [06:32:57.588] }, error = identity) [06:32:57.588] }) [06:32:57.588] } [06:32:57.601] - globals: [1] '...future.x_ii' [06:32:57.601] List of 1 [06:32:57.601] $ ...future.x_ii: num 42 [06:32:57.601] - attr(*, "where")=List of 1 [06:32:57.601] ..$ ...future.x_ii: [06:32:57.601] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.601] - attr(*, "resolved")= logi FALSE [06:32:57.601] - attr(*, "total_size")= num 39 [06:32:57.606] - packages: [1] 'doFuture' [06:32:57.606] - identifying globals and packages ... DONE [06:32:57.606] Launching 1 futures (chunks) ... [06:32:57.607] Chunk #1 of 1 ... [06:32:57.607] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.608] [06:32:57.608] [06:32:57.608] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.608] - seeds: [06:32:57.615] Chunk #1 of 1 ... DONE [06:32:57.615] Launching 1 futures (chunks) ... DONE [06:32:57.616] - resolving futures [06:32:57.616] - gathering results & relaying conditions (except errors) [06:32:57.617] - Number of value chunks collected: 1 [06:32:57.617] Resolving 1 futures (chunks) ... DONE [06:32:57.617] Reducing values from 1 chunks ... [06:32:57.618] Raw results: [06:32:57.618] List of 1 [06:32:57.618] $ :List of 2 [06:32:57.618] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.618] .. ..$ label : chr "inner" [06:32:57.618] .. ..$ idx : int 3 [06:32:57.618] .. ..$ pid : int 43768 [06:32:57.618] .. ..$ maxSize: num 1234000 [06:32:57.618] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.618] .. ..$ label : chr "inner" [06:32:57.618] .. ..$ idx : int 4 [06:32:57.618] .. ..$ pid : int 43768 [06:32:57.618] .. ..$ maxSize: num 1234000 [06:32:57.628] Combined results: [06:32:57.628] List of 2 [06:32:57.628] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.628] ..$ label : chr "inner" [06:32:57.628] ..$ idx : int 3 [06:32:57.628] ..$ pid : int 43768 [06:32:57.628] ..$ maxSize: num 1234000 [06:32:57.628] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.628] ..$ label : chr "inner" [06:32:57.628] ..$ idx : int 4 [06:32:57.628] ..$ pid : int 43768 [06:32:57.628] ..$ maxSize: num 1234000 [06:32:57.633] - accumulating results [06:32:57.634] - extracting results [06:32:57.634] doFuture2() ... DONE [06:32:57.636] doFuture2() ... [06:32:57.637] Number of chunks: 1 [06:32:57.637] Number of futures (= number of chunks): 1 [06:32:57.637] seed = FALSE [06:32:57.638] NULL [06:32:57.638] seed = FALSE [06:32:57.638] seed = FALSE [06:32:57.639] - %dofuture% R expression: [06:32:57.639] { [06:32:57.639] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.639] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.639] } [06:32:57.639] - foreach iterator arguments: [1] 'x' [06:32:57.640] - dummy globals (as locals): [1] 'x' [06:32:57.640] - R expression (map-reduce expression adjusted for RNG): [06:32:57.640] { [06:32:57.640] NULL [06:32:57.640] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.640] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.640] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.640] { [06:32:57.640] NULL [06:32:57.640] x <- NULL [06:32:57.640] } [06:32:57.640] ...future.env <- environment() [06:32:57.640] local({ [06:32:57.640] for (name in names(...future.x_jj)) { [06:32:57.640] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.640] inherits = FALSE) [06:32:57.640] } [06:32:57.640] }) [06:32:57.640] NULL [06:32:57.640] tryCatch({ [06:32:57.640] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.640] maxSize = getOption("future.globals.maxSize", [06:32:57.640] NA_real_)) [06:32:57.640] }, error = identity) [06:32:57.640] }) [06:32:57.640] } [06:32:57.641] - identifying globals and packages ... [06:32:57.641] - Argument 'globals': [06:32:57.641] logi TRUE [06:32:57.641] - attr(*, "add")= chr "...future.x_ii" [06:32:57.641] - attr(*, "ignore")= chr "x" [06:32:57.643] - R expression (map-reduce expression searched for globals): [06:32:57.643] { [06:32:57.643] NULL [06:32:57.643] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.643] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.643] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.643] { [06:32:57.643] NULL [06:32:57.643] x <- NULL [06:32:57.643] } [06:32:57.643] ...future.env <- environment() [06:32:57.643] local({ [06:32:57.643] for (name in names(...future.x_jj)) { [06:32:57.643] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.643] inherits = FALSE) [06:32:57.643] } [06:32:57.643] }) [06:32:57.643] NULL [06:32:57.643] tryCatch({ [06:32:57.643] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.643] maxSize = getOption("future.globals.maxSize", [06:32:57.643] NA_real_)) [06:32:57.643] }, error = identity) [06:32:57.643] }) [06:32:57.643] } [06:32:57.655] - globals: [1] '...future.x_ii' [06:32:57.655] List of 1 [06:32:57.655] $ ...future.x_ii: num 42 [06:32:57.655] - attr(*, "where")=List of 1 [06:32:57.655] ..$ ...future.x_ii: [06:32:57.655] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.655] - attr(*, "resolved")= logi FALSE [06:32:57.655] - attr(*, "total_size")= num 39 [06:32:57.659] - packages: [1] 'doFuture' [06:32:57.660] - identifying globals and packages ... DONE [06:32:57.660] Launching 1 futures (chunks) ... [06:32:57.660] Chunk #1 of 1 ... [06:32:57.660] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.661] [06:32:57.661] [06:32:57.662] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.662] - seeds: [06:32:57.668] Chunk #1 of 1 ... DONE [06:32:57.669] Launching 1 futures (chunks) ... DONE [06:32:57.669] - resolving futures [06:32:57.669] - gathering results & relaying conditions (except errors) [06:32:57.670] - Number of value chunks collected: 1 [06:32:57.670] Resolving 1 futures (chunks) ... DONE [06:32:57.671] Reducing values from 1 chunks ... [06:32:57.671] Raw results: [06:32:57.671] List of 1 [06:32:57.671] $ :List of 2 [06:32:57.671] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.671] .. ..$ label : chr "inner" [06:32:57.671] .. ..$ idx : int 3 [06:32:57.671] .. ..$ pid : int 43768 [06:32:57.671] .. ..$ maxSize: num 1234000 [06:32:57.671] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.671] .. ..$ label : chr "inner" [06:32:57.671] .. ..$ idx : int 4 [06:32:57.671] .. ..$ pid : int 43768 [06:32:57.671] .. ..$ maxSize: num 1234000 [06:32:57.678] Combined results: [06:32:57.678] List of 2 [06:32:57.678] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.678] ..$ label : chr "inner" [06:32:57.678] ..$ idx : int 3 [06:32:57.678] ..$ pid : int 43768 [06:32:57.678] ..$ maxSize: num 1234000 [06:32:57.678] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.678] ..$ label : chr "inner" [06:32:57.678] ..$ idx : int 4 [06:32:57.678] ..$ pid : int 43768 [06:32:57.678] ..$ maxSize: num 1234000 [06:32:57.685] - accumulating results [06:32:57.685] - extracting results [06:32:57.686] doFuture2() ... DONE [06:32:57.701] - Number of value chunks collected: 1 [06:32:57.701] Resolving 1 futures (chunks) ... DONE [06:32:57.701] Reducing values from 1 chunks ... [06:32:57.702] Raw results: [06:32:57.702] List of 1 [06:32:57.702] $ :List of 2 [06:32:57.702] ..$ :'data.frame': 3 obs. of 4 variables: [06:32:57.702] .. ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.702] .. ..$ idx : int [1:3] 1 3 4 [06:32:57.702] .. ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.702] .. ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.702] ..$ :'data.frame': 3 obs. of 4 variables: [06:32:57.702] .. ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.702] .. ..$ idx : int [1:3] 2 3 4 [06:32:57.702] .. ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.702] .. ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.708] Combined results: [06:32:57.709] List of 2 [06:32:57.709] $ :'data.frame': 3 obs. of 4 variables: [06:32:57.709] ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.709] ..$ idx : int [1:3] 1 3 4 [06:32:57.709] ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.709] ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.709] $ :'data.frame': 3 obs. of 4 variables: [06:32:57.709] ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.709] ..$ idx : int [1:3] 2 3 4 [06:32:57.709] ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.709] ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.717] - accumulating results [06:32:57.718] - extracting results [06:32:57.718] doFuture2() ... DONE label idx pid maxSize 1 outer 1 43768 1234000 2 inner 3 43768 1234000 3 inner 4 43768 1234000 4 outer 2 43768 1234000 5 inner 3 43768 1234000 6 inner 4 43768 1234000 - plan('multisession') ... [06:32:57.736] doFuture2() ... [06:32:57.740] Number of chunks: 1 [06:32:57.741] Number of futures (= number of chunks): 1 [06:32:57.741] seed = FALSE [06:32:57.741] NULL [06:32:57.742] seed = FALSE [06:32:57.742] seed = FALSE [06:32:57.742] - %dofuture% R expression: [06:32:57.742] { [06:32:57.742] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:57.742] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.742] inner <- foreach(x = 3:4) %dofuture% { [06:32:57.742] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.742] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.742] } [06:32:57.742] inner <- do.call(rbind, inner) [06:32:57.742] rbind(outer, inner) [06:32:57.742] } [06:32:57.743] - foreach iterator arguments: [1] 'x' [06:32:57.743] - dummy globals (as locals): [1] 'x' [06:32:57.743] - R expression (map-reduce expression adjusted for RNG): [06:32:57.744] { [06:32:57.744] NULL [06:32:57.744] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.744] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.744] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.744] { [06:32:57.744] NULL [06:32:57.744] x <- NULL [06:32:57.744] } [06:32:57.744] ...future.env <- environment() [06:32:57.744] local({ [06:32:57.744] for (name in names(...future.x_jj)) { [06:32:57.744] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.744] inherits = FALSE) [06:32:57.744] } [06:32:57.744] }) [06:32:57.744] NULL [06:32:57.744] tryCatch({ [06:32:57.744] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:57.744] maxSize = getOption("future.globals.maxSize", [06:32:57.744] NA_real_)) [06:32:57.744] inner <- foreach(x = 3:4) %dofuture% { [06:32:57.744] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.744] maxSize = getOption("future.globals.maxSize", [06:32:57.744] NA_real_)) [06:32:57.744] } [06:32:57.744] inner <- do.call(rbind, inner) [06:32:57.744] rbind(outer, inner) [06:32:57.744] }, error = identity) [06:32:57.744] }) [06:32:57.744] } [06:32:57.744] - identifying globals and packages ... [06:32:57.745] - Argument 'globals': [06:32:57.745] logi TRUE [06:32:57.745] - attr(*, "add")= chr "...future.x_ii" [06:32:57.745] - attr(*, "ignore")= chr "x" [06:32:57.747] - R expression (map-reduce expression searched for globals): [06:32:57.747] { [06:32:57.747] NULL [06:32:57.747] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.747] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.747] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.747] { [06:32:57.747] NULL [06:32:57.747] x <- NULL [06:32:57.747] } [06:32:57.747] ...future.env <- environment() [06:32:57.747] local({ [06:32:57.747] for (name in names(...future.x_jj)) { [06:32:57.747] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.747] inherits = FALSE) [06:32:57.747] } [06:32:57.747] }) [06:32:57.747] NULL [06:32:57.747] tryCatch({ [06:32:57.747] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:57.747] maxSize = getOption("future.globals.maxSize", [06:32:57.747] NA_real_)) [06:32:57.747] inner <- foreach(x = 3:4) %dofuture% { [06:32:57.747] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.747] maxSize = getOption("future.globals.maxSize", [06:32:57.747] NA_real_)) [06:32:57.747] } [06:32:57.747] inner <- do.call(rbind, inner) [06:32:57.747] rbind(outer, inner) [06:32:57.747] }, error = identity) [06:32:57.747] }) [06:32:57.747] } [06:32:57.766] - globals: [1] '...future.x_ii' [06:32:57.767] List of 1 [06:32:57.767] $ ...future.x_ii: num 42 [06:32:57.767] - attr(*, "where")=List of 1 [06:32:57.767] ..$ ...future.x_ii: [06:32:57.767] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.767] - attr(*, "resolved")= logi FALSE [06:32:57.767] - attr(*, "total_size")= num 39 [06:32:57.772] - packages: [2] 'doFuture', 'foreach' [06:32:57.772] - identifying globals and packages ... DONE [06:32:57.773] Launching 1 futures (chunks) ... [06:32:57.773] Chunk #1 of 1 ... [06:32:57.773] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.774] [06:32:57.775] [06:32:57.775] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.775] - seeds: [06:32:57.977] Chunk #1 of 1 ... DONE [06:32:57.977] Launching 1 futures (chunks) ... DONE [06:32:57.978] - resolving futures [06:32:57.978] - gathering results & relaying conditions (except errors) [06:32:57.793] doFuture2() ... [06:32:57.799] Number of chunks: 1 [06:32:57.832] Number of futures (= number of chunks): 1 [06:32:57.832] seed = FALSE [06:32:57.833] NULL [06:32:57.833] seed = FALSE [06:32:57.834] seed = FALSE [06:32:57.834] - %dofuture% R expression: [06:32:57.834] { [06:32:57.834] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.834] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.834] } [06:32:57.835] - foreach iterator arguments: [1] 'x' [06:32:57.835] - dummy globals (as locals): [1] 'x' [06:32:57.836] - R expression (map-reduce expression adjusted for RNG): [06:32:57.836] { [06:32:57.836] NULL [06:32:57.836] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.836] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.836] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.836] { [06:32:57.836] NULL [06:32:57.836] x <- NULL [06:32:57.836] } [06:32:57.836] ...future.env <- environment() [06:32:57.836] local({ [06:32:57.836] for (name in names(...future.x_jj)) { [06:32:57.836] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.836] inherits = FALSE) [06:32:57.836] } [06:32:57.836] }) [06:32:57.836] NULL [06:32:57.836] tryCatch({ [06:32:57.836] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.836] maxSize = getOption("future.globals.maxSize", [06:32:57.836] NA_real_)) [06:32:57.836] }, error = identity) [06:32:57.836] }) [06:32:57.836] } [06:32:57.837] - identifying globals and packages ... [06:32:57.837] - Argument 'globals': [06:32:57.837] logi TRUE [06:32:57.837] - attr(*, "add")= chr "...future.x_ii" [06:32:57.837] - attr(*, "ignore")= chr "x" [06:32:57.840] - R expression (map-reduce expression searched for globals): [06:32:57.840] { [06:32:57.840] NULL [06:32:57.840] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.840] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.840] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.840] { [06:32:57.840] NULL [06:32:57.840] x <- NULL [06:32:57.840] } [06:32:57.840] ...future.env <- environment() [06:32:57.840] local({ [06:32:57.840] for (name in names(...future.x_jj)) { [06:32:57.840] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.840] inherits = FALSE) [06:32:57.840] } [06:32:57.840] }) [06:32:57.840] NULL [06:32:57.840] tryCatch({ [06:32:57.840] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.840] maxSize = getOption("future.globals.maxSize", [06:32:57.840] NA_real_)) [06:32:57.840] }, error = identity) [06:32:57.840] }) [06:32:57.840] } [06:32:57.854] - globals: [1] '...future.x_ii' [06:32:57.854] List of 1 [06:32:57.854] $ ...future.x_ii: num 42 [06:32:57.854] - attr(*, "where")=List of 1 [06:32:57.854] ..$ ...future.x_ii: [06:32:57.854] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.854] - attr(*, "resolved")= logi FALSE [06:32:57.854] - attr(*, "total_size")= num 39 [06:32:57.859] - packages: [1] 'doFuture' [06:32:57.859] - identifying globals and packages ... DONE [06:32:57.860] Launching 1 futures (chunks) ... [06:32:57.860] Chunk #1 of 1 ... [06:32:57.860] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.861] [06:32:57.861] [06:32:57.862] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.862] - seeds: [06:32:57.879] Chunk #1 of 1 ... DONE [06:32:57.879] Launching 1 futures (chunks) ... DONE [06:32:57.879] - resolving futures [06:32:57.880] - gathering results & relaying conditions (except errors) [06:32:57.881] - Number of value chunks collected: 1 [06:32:57.881] Resolving 1 futures (chunks) ... DONE [06:32:57.881] Reducing values from 1 chunks ... [06:32:57.882] Raw results: [06:32:57.882] List of 1 [06:32:57.882] $ :List of 2 [06:32:57.882] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.882] .. ..$ label : chr "inner" [06:32:57.882] .. ..$ idx : int 3 [06:32:57.882] .. ..$ pid : int 43768 [06:32:57.882] .. ..$ maxSize: num 1234000 [06:32:57.882] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.882] .. ..$ label : chr "inner" [06:32:57.882] .. ..$ idx : int 4 [06:32:57.882] .. ..$ pid : int 43768 [06:32:57.882] .. ..$ maxSize: num 1234000 [06:32:57.889] Combined results: [06:32:57.890] List of 2 [06:32:57.890] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.890] ..$ label : chr "inner" [06:32:57.890] ..$ idx : int 3 [06:32:57.890] ..$ pid : int 43768 [06:32:57.890] ..$ maxSize: num 1234000 [06:32:57.890] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.890] ..$ label : chr "inner" [06:32:57.890] ..$ idx : int 4 [06:32:57.890] ..$ pid : int 43768 [06:32:57.890] ..$ maxSize: num 1234000 [06:32:57.896] - accumulating results [06:32:57.897] - extracting results [06:32:57.897] doFuture2() ... DONE [06:32:57.898] doFuture2() ... [06:32:57.904] Number of chunks: 1 [06:32:57.905] Number of futures (= number of chunks): 1 [06:32:57.905] seed = FALSE [06:32:57.905] NULL [06:32:57.906] seed = FALSE [06:32:57.906] seed = FALSE [06:32:57.906] - %dofuture% R expression: [06:32:57.907] { [06:32:57.907] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.907] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:57.907] } [06:32:57.907] - foreach iterator arguments: [1] 'x' [06:32:57.908] - dummy globals (as locals): [1] 'x' [06:32:57.908] - R expression (map-reduce expression adjusted for RNG): [06:32:57.908] { [06:32:57.908] NULL [06:32:57.908] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.908] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.908] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.908] { [06:32:57.908] NULL [06:32:57.908] x <- NULL [06:32:57.908] } [06:32:57.908] ...future.env <- environment() [06:32:57.908] local({ [06:32:57.908] for (name in names(...future.x_jj)) { [06:32:57.908] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.908] inherits = FALSE) [06:32:57.908] } [06:32:57.908] }) [06:32:57.908] NULL [06:32:57.908] tryCatch({ [06:32:57.908] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.908] maxSize = getOption("future.globals.maxSize", [06:32:57.908] NA_real_)) [06:32:57.908] }, error = identity) [06:32:57.908] }) [06:32:57.908] } [06:32:57.909] - identifying globals and packages ... [06:32:57.909] - Argument 'globals': [06:32:57.910] logi TRUE [06:32:57.910] - attr(*, "add")= chr "...future.x_ii" [06:32:57.910] - attr(*, "ignore")= chr "x" [06:32:57.911] - R expression (map-reduce expression searched for globals): [06:32:57.912] { [06:32:57.912] NULL [06:32:57.912] "# doFuture():::doFuture2(): process chunk of elements" [06:32:57.912] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:57.912] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:57.912] { [06:32:57.912] NULL [06:32:57.912] x <- NULL [06:32:57.912] } [06:32:57.912] ...future.env <- environment() [06:32:57.912] local({ [06:32:57.912] for (name in names(...future.x_jj)) { [06:32:57.912] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:57.912] inherits = FALSE) [06:32:57.912] } [06:32:57.912] }) [06:32:57.912] NULL [06:32:57.912] tryCatch({ [06:32:57.912] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:57.912] maxSize = getOption("future.globals.maxSize", [06:32:57.912] NA_real_)) [06:32:57.912] }, error = identity) [06:32:57.912] }) [06:32:57.912] } [06:32:57.932] - globals: [1] '...future.x_ii' [06:32:57.932] List of 1 [06:32:57.932] $ ...future.x_ii: num 42 [06:32:57.932] - attr(*, "where")=List of 1 [06:32:57.932] ..$ ...future.x_ii: [06:32:57.932] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:57.932] - attr(*, "resolved")= logi FALSE [06:32:57.932] - attr(*, "total_size")= num 39 [06:32:57.936] - packages: [1] 'doFuture' [06:32:57.936] - identifying globals and packages ... DONE [06:32:57.936] Launching 1 futures (chunks) ... [06:32:57.936] Chunk #1 of 1 ... [06:32:57.937] - Finding globals in 'args_list' for chunk #1 ... [06:32:57.937] [06:32:57.938] [06:32:57.938] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:57.938] - seeds: [06:32:57.952] Chunk #1 of 1 ... DONE [06:32:57.952] Launching 1 futures (chunks) ... DONE [06:32:57.952] - resolving futures [06:32:57.952] - gathering results & relaying conditions (except errors) [06:32:57.953] - Number of value chunks collected: 1 [06:32:57.954] Resolving 1 futures (chunks) ... DONE [06:32:57.954] Reducing values from 1 chunks ... [06:32:57.954] Raw results: [06:32:57.955] List of 1 [06:32:57.955] $ :List of 2 [06:32:57.955] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.955] .. ..$ label : chr "inner" [06:32:57.955] .. ..$ idx : int 3 [06:32:57.955] .. ..$ pid : int 43768 [06:32:57.955] .. ..$ maxSize: num 1234000 [06:32:57.955] ..$ :'data.frame': 1 obs. of 4 variables: [06:32:57.955] .. ..$ label : chr "inner" [06:32:57.955] .. ..$ idx : int 4 [06:32:57.955] .. ..$ pid : int 43768 [06:32:57.955] .. ..$ maxSize: num 1234000 [06:32:57.962] Combined results: [06:32:57.963] List of 2 [06:32:57.963] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.963] ..$ label : chr "inner" [06:32:57.963] ..$ idx : int 3 [06:32:57.963] ..$ pid : int 43768 [06:32:57.963] ..$ maxSize: num 1234000 [06:32:57.963] $ :'data.frame': 1 obs. of 4 variables: [06:32:57.963] ..$ label : chr "inner" [06:32:57.963] ..$ idx : int 4 [06:32:57.963] ..$ pid : int 43768 [06:32:57.963] ..$ maxSize: num 1234000 [06:32:57.969] - accumulating results [06:32:57.970] - extracting results [06:32:57.970] doFuture2() ... DONE [06:32:57.986] - Number of value chunks collected: 1 [06:32:57.986] Resolving 1 futures (chunks) ... DONE [06:32:57.986] Reducing values from 1 chunks ... [06:32:57.987] Raw results: [06:32:57.987] List of 1 [06:32:57.987] $ :List of 2 [06:32:57.987] ..$ :'data.frame': 3 obs. of 4 variables: [06:32:57.987] .. ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.987] .. ..$ idx : int [1:3] 1 3 4 [06:32:57.987] .. ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.987] .. ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.987] ..$ :'data.frame': 3 obs. of 4 variables: [06:32:57.987] .. ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.987] .. ..$ idx : int [1:3] 2 3 4 [06:32:57.987] .. ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.987] .. ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.994] Combined results: [06:32:57.994] List of 2 [06:32:57.994] $ :'data.frame': 3 obs. of 4 variables: [06:32:57.994] ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.994] ..$ idx : int [1:3] 1 3 4 [06:32:57.994] ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.994] ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:57.994] $ :'data.frame': 3 obs. of 4 variables: [06:32:57.994] ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:57.994] ..$ idx : int [1:3] 2 3 4 [06:32:57.994] ..$ pid : int [1:3] 43768 43768 43768 [06:32:57.994] ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:58.000] - accumulating results [06:32:58.001] - extracting results [06:32:58.001] doFuture2() ... DONE label idx pid maxSize 1 outer 1 43768 1234000 2 inner 3 43768 1234000 3 inner 4 43768 1234000 4 outer 2 43768 1234000 5 inner 3 43768 1234000 6 inner 4 43768 1234000 Testing with 2 cores ... - plan('multisession') ... [06:32:59.164] doFuture2() ... [06:32:59.169] Number of chunks: 2 [06:32:59.169] Number of futures (= number of chunks): 2 [06:32:59.169] Rescaling option 'future.globals.maxSize' to account for the number of elements processed per chunk: [06:32:59.170] - Number of chunks: 2 [06:32:59.170] - globals.maxSize (original): 1234000 bytes [06:32:59.170] - globals.maxSize (adjusted): 2468000 bytes [06:32:59.170] - R expression (adjusted): [06:32:59.170] { [06:32:59.170] "# doFuture:::doFuture2(): preserve future option" [06:32:59.170] ...future.globals.maxSize.org <- getOption("future.globals.maxSize") [06:32:59.170] if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) { [06:32:59.170] oopts <- options(future.globals.maxSize = ...future.globals.maxSize) [06:32:59.170] on.exit(options(oopts), add = TRUE) [06:32:59.170] } [06:32:59.170] { [06:32:59.170] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:59.170] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:59.170] inner <- foreach(x = 3:4) %dofuture% { [06:32:59.170] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:59.170] maxSize = getOption("future.globals.maxSize", [06:32:59.170] NA_real_)) [06:32:59.170] } [06:32:59.170] inner <- do.call(rbind, inner) [06:32:59.170] rbind(outer, inner) [06:32:59.170] } [06:32:59.170] } [06:32:59.171] seed = FALSE [06:32:59.171] NULL [06:32:59.171] seed = FALSE [06:32:59.171] seed = FALSE [06:32:59.172] - %dofuture% R expression: [06:32:59.172] { [06:32:59.172] "# doFuture:::doFuture2(): preserve future option" [06:32:59.172] ...future.globals.maxSize.org <- getOption("future.globals.maxSize") [06:32:59.172] if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) { [06:32:59.172] oopts <- options(future.globals.maxSize = ...future.globals.maxSize) [06:32:59.172] on.exit(options(oopts), add = TRUE) [06:32:59.172] } [06:32:59.172] { [06:32:59.172] outer <- data.frame(label = "outer", idx = x, pid = Sys.getpid(), [06:32:59.172] maxSize = getOption("future.globals.maxSize", NA_real_)) [06:32:59.172] inner <- foreach(x = 3:4) %dofuture% { [06:32:59.172] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:59.172] maxSize = getOption("future.globals.maxSize", [06:32:59.172] NA_real_)) [06:32:59.172] } [06:32:59.172] inner <- do.call(rbind, inner) [06:32:59.172] rbind(outer, inner) [06:32:59.172] } [06:32:59.172] } [06:32:59.173] - foreach iterator arguments: [1] 'x' [06:32:59.173] - dummy globals (as locals): [1] 'x' [06:32:59.173] - R expression (map-reduce expression adjusted for RNG): [06:32:59.174] { [06:32:59.174] NULL [06:32:59.174] "# doFuture():::doFuture2(): process chunk of elements" [06:32:59.174] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:59.174] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:59.174] { [06:32:59.174] NULL [06:32:59.174] x <- NULL [06:32:59.174] } [06:32:59.174] ...future.env <- environment() [06:32:59.174] local({ [06:32:59.174] for (name in names(...future.x_jj)) { [06:32:59.174] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:59.174] inherits = FALSE) [06:32:59.174] } [06:32:59.174] }) [06:32:59.174] NULL [06:32:59.174] tryCatch({ [06:32:59.174] "# doFuture:::doFuture2(): preserve future option" [06:32:59.174] ...future.globals.maxSize.org <- getOption("future.globals.maxSize") [06:32:59.174] if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) { [06:32:59.174] oopts <- options(future.globals.maxSize = ...future.globals.maxSize) [06:32:59.174] on.exit(options(oopts), add = TRUE) [06:32:59.174] } [06:32:59.174] { [06:32:59.174] outer <- data.frame(label = "outer", idx = x, [06:32:59.174] pid = Sys.getpid(), maxSize = getOption("future.globals.maxSize", [06:32:59.174] NA_real_)) [06:32:59.174] inner <- foreach(x = 3:4) %dofuture% { [06:32:59.174] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:59.174] maxSize = getOption("future.globals.maxSize", [06:32:59.174] NA_real_)) [06:32:59.174] } [06:32:59.174] inner <- do.call(rbind, inner) [06:32:59.174] rbind(outer, inner) [06:32:59.174] } [06:32:59.174] }, error = identity) [06:32:59.174] }) [06:32:59.174] } [06:32:59.175] - identifying globals and packages ... [06:32:59.175] - Argument 'globals': [06:32:59.175] logi TRUE [06:32:59.175] - attr(*, "add")= chr "...future.x_ii" [06:32:59.175] - attr(*, "ignore")= chr "x" [06:32:59.177] - R expression (map-reduce expression searched for globals): [06:32:59.177] { [06:32:59.177] NULL [06:32:59.177] "# doFuture():::doFuture2(): process chunk of elements" [06:32:59.177] lapply(seq_along(...future.x_ii), FUN = function(jj) { [06:32:59.177] ...future.x_jj <- ...future.x_ii[[jj]] [06:32:59.177] { [06:32:59.177] NULL [06:32:59.177] x <- NULL [06:32:59.177] } [06:32:59.177] ...future.env <- environment() [06:32:59.177] local({ [06:32:59.177] for (name in names(...future.x_jj)) { [06:32:59.177] assign(name, ...future.x_jj[[name]], envir = ...future.env, [06:32:59.177] inherits = FALSE) [06:32:59.177] } [06:32:59.177] }) [06:32:59.177] NULL [06:32:59.177] tryCatch({ [06:32:59.177] "# doFuture:::doFuture2(): preserve future option" [06:32:59.177] ...future.globals.maxSize.org <- getOption("future.globals.maxSize") [06:32:59.177] if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) { [06:32:59.177] oopts <- options(future.globals.maxSize = ...future.globals.maxSize) [06:32:59.177] on.exit(options(oopts), add = TRUE) [06:32:59.177] } [06:32:59.177] { [06:32:59.177] outer <- data.frame(label = "outer", idx = x, [06:32:59.177] pid = Sys.getpid(), maxSize = getOption("future.globals.maxSize", [06:32:59.177] NA_real_)) [06:32:59.177] inner <- foreach(x = 3:4) %dofuture% { [06:32:59.177] data.frame(label = "inner", idx = x, pid = Sys.getpid(), [06:32:59.177] maxSize = getOption("future.globals.maxSize", [06:32:59.177] NA_real_)) [06:32:59.177] } [06:32:59.177] inner <- do.call(rbind, inner) [06:32:59.177] rbind(outer, inner) [06:32:59.177] } [06:32:59.177] }, error = identity) [06:32:59.177] }) [06:32:59.177] } [06:32:59.201] - globals: [1] '...future.x_ii' [06:32:59.201] List of 1 [06:32:59.201] $ ...future.x_ii: num 42 [06:32:59.201] - attr(*, "where")=List of 1 [06:32:59.201] ..$ ...future.x_ii: [06:32:59.201] - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list" [06:32:59.201] - attr(*, "resolved")= logi FALSE [06:32:59.201] - attr(*, "total_size")= num 39 [06:32:59.206] - packages: [2] 'doFuture', 'foreach' [06:32:59.206] - identifying globals and packages ... DONE [06:32:59.206] Launching 2 futures (chunks) ... [06:32:59.207] Chunk #1 of 2 ... [06:32:59.207] - Finding globals in 'args_list' for chunk #1 ... [06:32:59.208] [06:32:59.208] [06:32:59.208] - Finding globals in 'args_list' for chunk #1 ... DONE [06:32:59.209] - seeds: [06:32:59.236] Chunk #1 of 2 ... DONE [06:32:59.236] Chunk #2 of 2 ... [06:32:59.237] - Finding globals in 'args_list' for chunk #2 ... [06:32:59.237] [06:32:59.238] [06:32:59.238] - Finding globals in 'args_list' for chunk #2 ... DONE [06:32:59.238] - seeds: [06:32:59.387] Chunk #2 of 2 ... DONE [06:32:59.387] Launching 2 futures (chunks) ... DONE [06:32:59.387] - resolving futures [06:32:59.388] - gathering results & relaying conditions (except errors) [06:32:59.627] - Number of value chunks collected: 2 [06:32:59.628] Resolving 2 futures (chunks) ... DONE [06:32:59.628] Reducing values from 2 chunks ... [06:32:59.629] Raw results: [06:32:59.629] List of 2 [06:32:59.629] $ :List of 1 [06:32:59.629] ..$ :'data.frame': 3 obs. of 4 variables: [06:32:59.629] .. ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:59.629] .. ..$ idx : int [1:3] 1 3 4 [06:32:59.629] .. ..$ pid : int [1:3] 174112 174112 174112 [06:32:59.629] .. ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:59.629] $ :List of 1 [06:32:59.629] ..$ :'data.frame': 3 obs. of 4 variables: [06:32:59.629] .. ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:59.629] .. ..$ idx : int [1:3] 2 3 4 [06:32:59.629] .. ..$ pid : int [1:3] 140868 140868 140868 [06:32:59.629] .. ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:59.639] Combined results: [06:32:59.639] List of 2 [06:32:59.639] $ :'data.frame': 3 obs. of 4 variables: [06:32:59.639] ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:59.639] ..$ idx : int [1:3] 1 3 4 [06:32:59.639] ..$ pid : int [1:3] 174112 174112 174112 [06:32:59.639] ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:59.639] $ :'data.frame': 3 obs. of 4 variables: [06:32:59.639] ..$ label : chr [1:3] "outer" "inner" "inner" [06:32:59.639] ..$ idx : int [1:3] 2 3 4 [06:32:59.639] ..$ pid : int [1:3] 140868 140868 140868 [06:32:59.639] ..$ maxSize: num [1:3] 1234000 1234000 1234000 [06:32:59.648] - accumulating results [06:32:59.649] - extracting results [06:32:59.649] doFuture2() ... DONE label idx pid maxSize 1 outer 1 174112 1234000 2 inner 3 174112 1234000 3 inner 4 174112 1234000 4 outer 2 140868 1234000 5 inner 3 140868 1234000 6 inner 4 140868 1234000 > > message("*** Options in nested parallelization ... done") *** Options in nested parallelization ... done > > source("incl/end.R") R version 4.5.0 alpha (2025-03-15 r87978 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.34.0 foreach_1.5.2 loaded via a namespace (and not attached): [1] compiler_4.5.0 parallelly_1.42.0 tools_4.5.0 [4] parallel_4.5.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.16.3 > > proc.time() user system elapsed 1.73 0.18 3.35