`cli` messages are always printed at the end of execution

[VasLem]

Describe the bug
Also referenced here . The cli package messages are not relayed when called within the future.apply context. This is even the case when no parallelism is used.

Reproduce example
The following waits for 10 seconds and prints hihihihihihihihihihi

future::plan(future::sequential)
ret <- future.apply::future_lapply(X = seq(10), future.stdout=NA,
                                    FUN=function(x) {
                                        cli::cli_inform('hi')
                                        Sys.sleep(1)
                                    })

[VasLem]

Having activated debug mode I am getting this:

ret <- future.apply::future_lapply(X = seq(10), future.stdout=NA,
                                    FUN=function(x) {
                                        cli::cli_inform('hi')
                                        Sys.sleep(1)
                                    })
[14:30:38.463] plan(<‘call’>, .skip = FALSE, .cleanup = NA, .init = TRUE) ...
[14:30:38.465] | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = NA, init = TRUE) ...
[14:30:38.466] | : all.equal() for FutureStrategyList ...
[14:30:38.466] | : . New stack:
[14:30:38.466] | : . List of 1
[14:30:38.466] | : .  $ :function (..., envir = parent.frame())  
[14:30:38.466] | : .   ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function"
[14:30:38.466] | : .   ..- attr(*, "init")= logi TRUE
[14:30:38.466] | : .   ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.466] | : .   .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.466] | : .   ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.466] | : .   ..- attr(*, "call")= language future::plan(future::sequential)
[14:30:38.466] | : .  - attr(*, "class")= chr [1:2] "FutureStrategyList" "list"
[14:30:38.477] | : . Old stack:
[14:30:38.478] | : . List of 1
[14:30:38.478] | : .  $ :function (..., envir = parent.frame())  
[14:30:38.478] | : .   ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function"
[14:30:38.478] | : .   ..- attr(*, "init")= chr "done"
[14:30:38.478] | : .   ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.478] | : .   .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.478] | : .   ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.478] | : .   ..- attr(*, "call")= language future::plan(future::sequential)
[14:30:38.478] | : .   ..- attr(*, "backend")=Classes 'SequentialFutureBackend', 'FutureBackend', 'environment' <environment: 0x5726f964b880> 
[14:30:38.478] | : .   .. ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.478] | : .   .. .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.478] | : .  - attr(*, "class")= chr [1:2] "FutureStrategyList" "list"
[14:30:38.489] | : . Not identical
[14:30:38.489] | : . all.equal() for future ...
[14:30:38.489] | : . ' List of 2
[14:30:38.489] | : . '  $ target :function (..., envir = parent.frame())  
[14:30:38.489] | : . '   ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function"
[14:30:38.489] | : . '   ..- attr(*, "init")= logi TRUE
[14:30:38.489] | : . '   ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.489] | : . '   .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.489] | : . '   ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.489] | : . '   ..- attr(*, "call")= language future::plan(future::sequential)
[14:30:38.489] | : . '  $ current:function (..., envir = parent.frame())  
[14:30:38.489] | : . '   ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function"
[14:30:38.489] | : . '   ..- attr(*, "init")= chr "done"
[14:30:38.489] | : . '   ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.489] | : . '   .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.489] | : . '   ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.489] | : . '   ..- attr(*, "call")= language future::plan(future::sequential)
[14:30:38.489] | : . '   ..- attr(*, "backend")=Classes 'SequentialFutureBackend', 'FutureBackend', 'environment' <environment: 0x5726f964b880> 
[14:30:38.489] | : . '   .. ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.489] | : . '   .. .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.499] | : . all.equal() for future ... done
[14:30:38.500] | : all.equal() for FutureStrategyList ... done
[14:30:38.501] | : plan(): Skip setting new future backend stack because it is the same as the current one:
[14:30:38.502] | : List of future strategies:
[14:30:38.502] | : 1. sequential:
[14:30:38.502] | :    - args: function (..., envir = parent.frame(), workers = "<NULL>")
[14:30:38.502] | :    - tweaked: FALSE
[14:30:38.502] | :    - call: future::plan(future::sequential)
[14:30:38.504] | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = NA, init = TRUE) ... done
[14:30:38.505] plan(<‘call’>, .skip = FALSE, .cleanup = NA, .init = TRUE) ... done
[14:30:38.509] future_lapply() ...
[14:30:38.512] | Globals in FUN(): [n=3] ‘{’, ‘::’, ‘Sys.sleep’
[14:30:38.513] | => Will pass '...' to FUN(): ‘{’, ‘    ...future.FUN(...future.X_jj, ...)’, ‘}’
[14:30:38.513] | future_lapply() -> future_xapply() ...
[14:30:38.514] | : nbrOfWorkers(NULL) ...
[14:30:38.515] | : . List of 4
[14:30:38.515] | : .  $ : language makeChunks(nX, nbrOfWorkers = nbrOfWorkers(), future.scheduling = future.scheduling,      future.chunk.size = future.chunk.size)
[14:30:38.515] | : .  $ : language stop_if_not(nbrOfElements >= 0L, nbrOfWorkers >= 1L)
[14:30:38.515] | : .  $ : language nbrOfWorkers()
[14:30:38.515] | : .  $ : language nbrOfWorkers.NULL()
[14:30:38.519] | : . plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ...
[14:30:38.519] | : . plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done
[14:30:38.520] | : . Number of workers: 1
[14:30:38.520] | : nbrOfWorkers(NULL) ... done
[14:30:38.520] | : Number of chunks: 1
[14:30:38.520] | : getGlobalsAndPackagesXApply() ...
[14:30:38.520] | : . future.globals: TRUE
[14:30:38.521] | : . getGlobalsAndPackages() ...
[14:30:38.521] | : . ' Searching for globals ...
[14:30:38.537] | : . ' , globals found: [4] ‘FUN’, ‘{’, ‘::’, ‘Sys.sleep’
[14:30:38.537] | : . ' Searching for globals ... done
[14:30:38.538] | : . ' Resolving globals: FALSE
[14:30:38.538] | : . ' Search for packages associated with the globals ...
[14:30:38.538] | : . ' , Packages associated with globals: [1] ‘base’
[14:30:38.539] | : . ' , Packages: [1] ‘base’
[14:30:38.540] | : . ' Search for packages associated with the globals ... done
[14:30:38.540] | : . ' The total size of the 1 globals is 1.24 KiB (1271 bytes)
[14:30:38.542] | : . ' The total size of the 1 globals exported for future expression (‘FUN()’) is 1.24 KiB There is one global: ‘FUN’ (1.24 KiB of class ‘function’)
[14:30:38.542] | : . ' Packages after dropping 'base': [0] 
[14:30:38.543] | : . ' globals: [1] ‘FUN’
[14:30:38.543] | : . ' packages: [0] 
[14:30:38.545] | : . getGlobalsAndPackages() ... done
[14:30:38.545] | : . globals found/used: [n=1] ‘FUN’
[14:30:38.546] | : . needed namespaces: [n=0] 
[14:30:38.547] | : . use_args: TRUE
[14:30:38.547] | : . Getting '...' globals ...
[14:30:38.548] | : . ' resolve() for FutureGlobals ...
[14:30:38.549] | : . ' , recursive: 0
[14:30:38.550] | : . ' , Number of elements: 1
[14:30:38.550] | : . ' , elements: ‘...’
[14:30:38.551] | : . ' , 'obj' is DotDotDotList
[14:30:38.551] | : . ' , resolve(obj, ...) ...
[14:30:38.552] | : . ' , ; resolve() for DotDotDotList ...
[14:30:38.552] | : . ' , ; ` recursive: -1
[14:30:38.553] | : . ' , ; resolve() for DotDotDotList ... done
[14:30:38.554] | : . ' , resolve(obj, ...) ... done
[14:30:38.554] | : . ' , resolved() ...
[14:30:38.555] | : . ' , ; resolved() for DotDotDotList ...
[14:30:38.555] | : . ' , ; ` Number of elements: 0
[14:30:38.555] | : . ' , ; ` Number of futures: 0
[14:30:38.555] | : . ' , ; resolved() for DotDotDotList ... done
[14:30:38.556] | : . ' , resolved() ... done
[14:30:38.556] | : . ' , length: 0 (resolved future 1)
[14:30:38.556] | : . ' resolve() for FutureGlobals ... done
[14:30:38.556] | : . ' '...' content: [n=0] 
[14:30:38.556] | : . ' List of 1
[14:30:38.556] | : . '  $ ...: list()
[14:30:38.556] | : . '   ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
[14:30:38.556] | : . '  - attr(*, "where")=List of 1
[14:30:38.556] | : . '   ..$ ...:<environment: 0x5726f78d0ae8> 
[14:30:38.556] | : . '  - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
[14:30:38.556] | : . '  - attr(*, "resolved")= logi TRUE
[14:30:38.556] | : . '  - attr(*, "total_size")= num NA
[14:30:38.564] | : . Getting '...' globals ... done
[14:30:38.565] | : . Globals to be used in all futures (chunks): [n=2] ‘...future.FUN’, ‘...’
[14:30:38.566] | : . List of 2
[14:30:38.566] | : .  $ ...future.FUN:function (x)  
[14:30:38.566] | : .   ..- attr(*, "srcref")= 'srcref' int [1:8] 2 41 5 37 41 37 2 5
[14:30:38.566] | : .   .. ..- attr(*, "srcfile")=Classes 'srcfilecopy', 'srcfile' <environment: 0x5726f78d35a0> 
[14:30:38.566] | : .  $ ...          : list()
[14:30:38.566] | : .   ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
[14:30:38.566] | : .  - attr(*, "where")=List of 2
[14:30:38.566] | : .   ..$ ...future.FUN:<environment: 0x5726f78d0ae8> 
[14:30:38.566] | : .   ..$ ...          :<environment: 0x5726f78d0ae8> 
[14:30:38.566] | : .  - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
[14:30:38.566] | : .  - attr(*, "resolved")= logi FALSE
[14:30:38.566] | : .  - attr(*, "total_size")= num 5755
[14:30:38.585] | : . Packages to be attached in all futures: [n=0] 
[14:30:38.585] | : getGlobalsAndPackagesXApply() ... done
[14:30:38.586] | : Globals pass to each chunk: [n=5] ‘...future.FUN’, ‘...’, ‘...future.elements_ii’, ‘...future.seeds_ii’, ‘...future.globals.maxSize’
[14:30:38.586] | : List of 5
[14:30:38.586] | :  $ ...future.FUN            :function (x)  
[14:30:38.586] | :   ..- attr(*, "srcref")= 'srcref' int [1:8] 2 41 5 37 41 37 2 5
[14:30:38.586] | :   .. ..- attr(*, "srcfile")=Classes 'srcfilecopy', 'srcfile' <environment: 0x5726f78d35a0> 
[14:30:38.586] | :  $ ...                      : list()
[14:30:38.586] | :   ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
[14:30:38.586] | :  $ ...future.elements_ii    : NULL
[14:30:38.586] | :  $ ...future.seeds_ii       : NULL
[14:30:38.586] | :  $ ...future.globals.maxSize: NULL
[14:30:38.586] | :  - attr(*, "where")=List of 5
[14:30:38.586] | :   ..$ ...future.FUN            :<environment: 0x5726f78d0ae8> 
[14:30:38.586] | :   ..$ ...                      :<environment: 0x5726f78d0ae8> 
[14:30:38.586] | :   ..$ ...future.elements_ii    :<environment: R_EmptyEnv> 
[14:30:38.586] | :   ..$ ...future.seeds_ii       :<environment: R_EmptyEnv> 
[14:30:38.586] | :   ..$ ...future.globals.maxSize:<environment: R_EmptyEnv> 
[14:30:38.586] | :  - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
[14:30:38.586] | :  - attr(*, "resolved")= logi FALSE
[14:30:38.586] | :  - attr(*, "total_size")= num 5755
[14:30:38.595] | : Number of futures (= number of chunks): 1
[14:30:38.595] | : Launching 1 futures (chunks) ...
[14:30:38.595] | : Chunk #1 of 1 ...
[14:30:38.595] | :  - Finding globals in 'X' for chunk #1 ...
[14:30:38.595] | : getGlobalsAndPackages() ...
[14:30:38.596] | : . Searching for globals ...
[14:30:38.596] | : . ' globals found: [0] 
[14:30:38.596] | : . Searching for globals ... done
[14:30:38.596] | : . globals: [0] <none>
[14:30:38.596] | : . packages: [0] <none>
[14:30:38.597] | : getGlobalsAndPackages() ... done
[14:30:38.597] | :    + additional globals found: [n=0] 
[14:30:38.597] | :    + additional namespaces needed: [n=0] 
[14:30:38.597] | :  - Finding globals in 'X' for chunk #1 ... DONE
[14:30:38.597] | :  - seeds: <none>
[14:30:38.597] | :  - All globals exported: [n=5] ‘...future.FUN’, ‘...’, ‘...future.elements_ii’, ‘...future.seeds_ii’, ‘...future.globals.maxSize’
[14:30:38.597] | : future(..., label = ‘future_lapply-1’) ...
[14:30:38.597] | : . lazy: FALSE
[14:30:38.597] | : . stdout: NA
[14:30:38.598] | : . conditions: [n=1] ‘condition’
[14:30:38.598] | : . gc: FALSE
[14:30:38.598] | : . earlySignal: FALSE
[14:30:38.598] | : . getGlobalsAndPackages() ...
[14:30:38.598] | : . ' globals passed as-is: [5] ‘...future.FUN’, ‘...’, ‘...future.elements_ii’, ‘...future.seeds_ii’, ‘...future.globals.maxSize’
[14:30:38.598] | : . ' Resolving globals: FALSE
[14:30:38.598] | : . ' Tweak future expression to call with '...' arguments ...
[14:30:38.598] | : . ' , {
[14:30:38.598] | : . ' ,     "# future::getGlobalsAndPackages(): wrapping the original future"
[14:30:38.598] | : . ' ,     "# expression in do.call(), because function called uses '...'  "
[14:30:38.598] | : . ' ,     "# as a global variable                                         "
[14:30:38.598] | : . ' ,     do.call(function(...) {
[14:30:38.598] | : . ' ,         "# future::getGlobalsAndPackages(): FUN() uses '...' internally "
[14:30:38.598] | : . ' ,         "# without having an '...' argument. This means '...' is treated"
[14:30:38.598] | : . ' ,         "# as a global variable. This may happen when FUN() is an       "
[14:30:38.598] | : . ' ,         "# anonymous function.                                          "
[14:30:38.598] | : . ' ,         "#                                                              "
[14:30:38.598] | : . ' ,         "# If an anonymous function, we will make sure to restore the   "
[14:30:38.598] | : . ' ,         "# function environment of FUN() to the calling environment.    "
[14:30:38.598] | : . ' ,         "# We assume FUN() an anonymous function if it lives in the     "
[14:30:38.598] | : . ' ,         "# global environment, which is where globals are written.      "
[14:30:38.598] | : . ' ,         penv <- env <- environment(...future.FUN)
[14:30:38.598] | : . ' ,         repeat {
[14:30:38.598] | : . ' ,             if (identical(env, globalenv()) || identical(env, 
[14:30:38.598] | : . ' ,                 emptyenv())) 
[14:30:38.598] | : . ' ,                 break
[14:30:38.598] | : . ' ,             penv <- env
[14:30:38.598] | : . ' ,             env <- parent.env(env)
[14:30:38.598] | : . ' ,         }
[14:30:38.598] | : . ' ,         if (identical(penv, globalenv())) {
[14:30:38.598] | : . ' ,             environment(...future.FUN) <- environment()
[14:30:38.598] | : . ' ,         }
[14:30:38.598] | : . ' ,         else if (!identical(penv, emptyenv()) && !is.null(penv) && 
[14:30:38.598] | : . ' ,             !isNamespace(penv)) {
[14:30:38.598] | : . ' ,             parent.env(penv) <- environment()
[14:30:38.598] | : . ' ,         }
[14:30:38.598] | : . ' ,         rm(list = c("env", "penv"), inherits = FALSE)
[14:30:38.598] | : . ' ,         {
[14:30:38.598] | : . ' ,             "# future.apply:::future_xapply(): preserve future option"
[14:30:38.598] | : . ' ,             ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
[14:30:38.598] | : . ' ,             if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
[14:30:38.598] | : . ' ,                 oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
[14:30:38.598] | : . ' ,                 on.exit(options(oopts), add = TRUE)
[14:30:38.598] | : . ' ,             }
[14:30:38.598] | : . ' ,             {
[14:30:38.598] | : . ' ,                 "# future.apply::future_lapply(): process chunk of elements"
[14:30:38.598] | : . ' ,                 lapply(seq_along(...future.elements_ii), FUN = function(jj) {
[14:30:38.598] | : . ' ,                   ...future.X_jj <- ...future.elements_ii[[jj]]
[14:30:38.598] | : . ' ,                   {
[14:30:38.598] | : . ' ,                     ...future.FUN(...future.X_jj, ...)
[14:30:38.598] | : . ' ,                   }
[14:30:38.598] | : . ' ,                 })
[14:30:38.598] | : . ' ,             }
[14:30:38.598] | : . ' ,         }
[14:30:38.598] | : . ' ,     }, args = future.call.arguments)
[14:30:38.598] | : . ' , }
[14:30:38.600] | : . ' Tweak future expression to call with '...' arguments ... done
[14:30:38.600] | : . ' Search for packages associated with the globals ...
[14:30:38.600] | : . ' , Packages associated with globals: [0] 
[14:30:38.600] | : . ' , Packages: [0] 
[14:30:38.600] | : . ' Search for packages associated with the globals ... done
[14:30:38.601] | : . ' Packages after dropping 'base': [0] 
[14:30:38.601] | : . ' globals: [5] ‘...future.FUN’, ‘future.call.arguments’, ‘...future.elements_ii’, ‘...future.seeds_ii’, ‘...future.globals.maxSize’
[14:30:38.601] | : . ' packages: [0] 
[14:30:38.601] | : . getGlobalsAndPackages() ... done
[14:30:38.601] | : . run() for ‘Future’ (‘future_lapply-1’) ...
[14:30:38.601] | : . ' state: ‘created’
[14:30:38.602] | : . ' plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ...
[14:30:38.602] | : . ' plan("backend", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done
[14:30:38.602] | : . ' Using SequentialFutureBackend ...
[14:30:38.602] | : . ' , Number of futures since start: 1 (1 created, 1 launched, 1 finished)
[14:30:38.602] | : . ' , Launching futures ...
[14:30:38.602] | : . ' , ; launchFuture() for ‘SequentialFutureBackend’, ‘FutureBackend’, ‘environment’ ...
[14:30:38.602] | : . ' , ; ` getFutureData() ...
[14:30:38.602] | : . ' , ; ` | getFutureCore() ...
[14:30:38.603] | : . ' , ; ` | : Packages needed by the future expression (n = 0): <none>
[14:30:38.603] | : . ' , ; ` | getFutureCore() ... done
[14:30:38.603] | : . ' , ; ` | getFutureCapture() ...
[14:30:38.603] | : . ' , ; ` | getFutureCapture() ... done
[14:30:38.603] | : . ' , ; ` | getFutureContext() ...
[14:30:38.603] | : . ' , ; ` | : plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ...
[14:30:38.603] | : . ' , ; ` | : . Getting stack without first backend: [n=0] 
[14:30:38.603] | : . ' , ; ` | : plan("tail", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done
[14:30:38.603] | : . ' , ; ` | : Packages needed by future backend (n = 0): <none>
[14:30:38.604] | : . ' , ; ` | getFutureContext() ... done
[14:30:38.604] | : . ' , ; ` getFutureData() ... done
[14:30:38.607] | : . ' , ; ` plan("list", .skip = FALSE, .cleanup = NA, .init = TRUE) ...
[14:30:38.607] | : . ' , ; ` | Getting full stack: [n=1] ‘sequential’, ‘uniprocess’, ‘future’, ‘function’
[14:30:38.608] | : . ' , ; ` plan("list", .skip = FALSE, .cleanup = NA, .init = TRUE) ... done
[14:30:38.608] | : . ' , ; ` plan(<‘name’>, .skip = FALSE, .cleanup = FALSE, .init = FALSE) ...
[14:30:38.608] | : . ' , ; ` | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = FALSE, init = FALSE) ...
[14:30:38.608] | : . ' , ; ` | : all.equal() for FutureStrategyList ...
[14:30:38.608] | : . ' , ; ` | : . New stack:
[14:30:38.609] | : . ' , ; ` | : . List of 1
[14:30:38.609] | : . ' , ; ` | : .  $ :function (..., envir = parent.frame())  
[14:30:38.609] | : . ' , ; ` | : .   ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function"
[14:30:38.609] | : . ' , ; ` | : .   ..- attr(*, "init")= logi TRUE
[14:30:38.609] | : . ' , ; ` | : .   ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.609] | : . ' , ; ` | : .   .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.609] | : . ' , ; ` | : .   ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.609] | : . ' , ; ` | : .   ..- attr(*, "call")= language plan(strategiesR, .cleanup = FALSE, .init = FALSE)
[14:30:38.609] | : . ' , ; ` | : .  - attr(*, "class")= chr [1:2] "FutureStrategyList" "list"
[14:30:38.611] | : . ' , ; ` | : . Old stack:
[14:30:38.612] | : . ' , ; ` | : . List of 1
[14:30:38.612] | : . ' , ; ` | : .  $ :function (..., envir = parent.frame())  
[14:30:38.612] | : . ' , ; ` | : .   ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function"
[14:30:38.612] | : . ' , ; ` | : .   ..- attr(*, "init")= chr "done"
[14:30:38.612] | : . ' , ; ` | : .   ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.612] | : . ' , ; ` | : .   .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.612] | : . ' , ; ` | : .   ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.612] | : . ' , ; ` | : .   ..- attr(*, "call")= language future::plan(future::sequential)
[14:30:38.612] | : . ' , ; ` | : .   ..- attr(*, "backend")=Classes 'SequentialFutureBackend', 'FutureBackend', 'environment' <environment: 0x5726f964b880> 
[14:30:38.612] | : . ' , ; ` | : .   .. ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.612] | : . ' , ; ` | : .   .. .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.612] | : . ' , ; ` | : .  - attr(*, "class")= chr [1:2] "FutureStrategyList" "list"
[14:30:38.615] | : . ' , ; ` | : . Not identical
[14:30:38.615] | : . ' , ; ` | : . all.equal() for future ...
[14:30:38.615] | : . ' , ; ` | : . ' List of 2
[14:30:38.615] | : . ' , ; ` | : . '  $ target :function (..., envir = parent.frame())  
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function"
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "init")= logi TRUE
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.615] | : . ' , ; ` | : . '   .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "call")= language plan(strategiesR, .cleanup = FALSE, .init = FALSE)
[14:30:38.615] | : . ' , ; ` | : . '  $ current:function (..., envir = parent.frame())  
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function"
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "init")= chr "done"
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.615] | : . ' , ; ` | : . '   .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "call")= language future::plan(future::sequential)
[14:30:38.615] | : . ' , ; ` | : . '   ..- attr(*, "backend")=Classes 'SequentialFutureBackend', 'FutureBackend', 'environment' <environment: 0x5726f964b880> 
[14:30:38.615] | : . ' , ; ` | : . '   .. ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:38.615] | : . ' , ; ` | : . '   .. .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:38.624] | : . ' , ; ` | : . all.equal() for future ... done
[14:30:38.624] | : . ' , ; ` | : all.equal() for FutureStrategyList ... done
[14:30:38.624] | : . ' , ; ` | : plan(): Skip setting new future backend stack because it is the same as the current one:
[14:30:38.624] | : . ' , ; ` | : List of future strategies:
[14:30:38.624] | : . ' , ; ` | : 1. sequential:
[14:30:38.624] | : . ' , ; ` | :    - args: function (..., envir = parent.frame(), workers = "<NULL>")
[14:30:38.624] | : . ' , ; ` | :    - tweaked: FALSE
[14:30:38.624] | : . ' , ; ` | :    - call: future::plan(future::sequential)
[14:30:38.625] | : . ' , ; ` | plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = FALSE, init = FALSE) ... done
[14:30:38.625] | : . ' , ; ` plan(<‘name’>, .skip = FALSE, .cleanup = FALSE, .init = FALSE) ... done
[14:30:38.625] | : . ' , ; ` assign_globals() ...
[14:30:38.625] | : . ' , ; ` List of 5
[14:30:38.625] | : . ' , ; `  $ ...future.FUN            :function (x)  
[14:30:38.625] | : . ' , ; `   ..- attr(*, "srcref")= 'srcref' int [1:8] 2 41 5 37 41 37 2 5
[14:30:38.625] | : . ' , ; `   .. ..- attr(*, "srcfile")=Classes 'srcfilecopy', 'srcfile' <environment: 0x5726f78d35a0> 
[14:30:38.625] | : . ' , ; `  $ future.call.arguments    : list()
[14:30:38.625] | : . ' , ; `   ..- attr(*, "class")= chr [1:2] "DotDotDotList" "list"
[14:30:38.625] | : . ' , ; `  $ ...future.elements_ii    :List of 10
[14:30:38.625] | : . ' , ; `   ..$ : int 1
[14:30:38.625] | : . ' , ; `   ..$ : int 2
[14:30:38.625] | : . ' , ; `   ..$ : int 3
[14:30:38.625] | : . ' , ; `   ..$ : int 4
[14:30:38.625] | : . ' , ; `   ..$ : int 5
[14:30:38.625] | : . ' , ; `   ..$ : int 6
[14:30:38.625] | : . ' , ; `   ..$ : int 7
[14:30:38.625] | : . ' , ; `   ..$ : int 8
[14:30:38.625] | : . ' , ; `   ..$ : int 9
[14:30:38.625] | : . ' , ; `   ..$ : int 10
[14:30:38.625] | : . ' , ; `  $ ...future.seeds_ii       : NULL
[14:30:38.625] | : . ' , ; `  $ ...future.globals.maxSize: NULL
[14:30:38.625] | : . ' , ; `  - attr(*, "where")=List of 5
[14:30:38.625] | : . ' , ; `   ..$ ...future.FUN            :<environment: 0x5726f78d0ae8> 
[14:30:38.625] | : . ' , ; `   ..$ future.call.arguments    :<environment: 0x5726f78d0ae8> 
[14:30:38.625] | : . ' , ; `   ..$ ...future.elements_ii    :<environment: R_EmptyEnv> 
[14:30:38.625] | : . ' , ; `   ..$ ...future.seeds_ii       :<environment: R_EmptyEnv> 
[14:30:38.625] | : . ' , ; `   ..$ ...future.globals.maxSize:<environment: R_EmptyEnv> 
[14:30:38.625] | : . ' , ; `  - attr(*, "resolved")= logi FALSE
[14:30:38.625] | : . ' , ; `  - attr(*, "total_size")= num 5755
[14:30:38.625] | : . ' , ; `  - attr(*, "class")= chr [1:3] "FutureGlobals" "Globals" "list"
[14:30:38.625] | : . ' , ; `  - attr(*, "already-done")= logi TRUE
[14:30:38.633] | : . ' , ; ` - copied ‘...future.FUN’ to environment
[14:30:38.633] | : . ' , ; ` - copied ‘future.call.arguments’ to environment
[14:30:38.633] | : . ' , ; ` - copied ‘...future.elements_ii’ to environment
[14:30:38.633] | : . ' , ; ` - copied ‘...future.seeds_ii’ to environment
[14:30:38.633] | : . ' , ; ` - copied ‘...future.globals.maxSize’ to environment
[14:30:38.634] | : . ' , ; ` assign_globals() ... done
[14:30:48.964] | : . ' , ; ` plan(<‘name’>, .skip = FALSE, .cleanup = FALSE, .init = FALSE) ...
[14:30:48.965] | : . ' , ; ` | plan(<‘FutureStrategyList’>, .skip = FALSE, .cleanup = FALSE, .init = FALSE) ...
[14:30:48.965] | : . ' , ; ` | : plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = FALSE, init = FALSE) ...
[14:30:48.965] | : . ' , ; ` | : . all.equal() for FutureStrategyList ...
[14:30:48.965] | : . ' , ; ` | : . ' New stack:
[14:30:48.966] | : . ' , ; ` | : . ' List of 1
[14:30:48.966] | : . ' , ; ` | : . '  $ :function (..., envir = parent.frame())  
[14:30:48.966] | : . ' , ; ` | : . '   ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function"
[14:30:48.966] | : . ' , ; ` | : . '   ..- attr(*, "init")= chr "done"
[14:30:48.966] | : . ' , ; ` | : . '   ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:48.966] | : . ' , ; ` | : . '   .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:48.966] | : . ' , ; ` | : . '   ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:48.966] | : . ' , ; ` | : . '   ..- attr(*, "call")= language future::plan(future::sequential)
[14:30:48.966] | : . ' , ; ` | : . '   ..- attr(*, "backend")=Classes 'SequentialFutureBackend', 'FutureBackend', 'environment' <environment: 0x5726f964b880> 
[14:30:48.966] | : . ' , ; ` | : . '   .. ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:48.966] | : . ' , ; ` | : . '   .. .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:48.966] | : . ' , ; ` | : . '  - attr(*, "class")= chr [1:2] "FutureStrategyList" "list"
[14:30:48.972] | : . ' , ; ` | : . ' Old stack:
[14:30:48.972] | : . ' , ; ` | : . ' List of 1
[14:30:48.972] | : . ' , ; ` | : . '  $ :function (..., envir = parent.frame())  
[14:30:48.972] | : . ' , ; ` | : . '   ..- attr(*, "class")= chr [1:4] "sequential" "uniprocess" "future" "function"
[14:30:48.972] | : . ' , ; ` | : . '   ..- attr(*, "init")= chr "done"
[14:30:48.972] | : . ' , ; ` | : . '   ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:48.972] | : . ' , ; ` | : . '   .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:48.972] | : . ' , ; ` | : . '   ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:48.972] | : . ' , ; ` | : . '   ..- attr(*, "call")= language future::plan(future::sequential)
[14:30:48.972] | : . ' , ; ` | : . '   ..- attr(*, "backend")=Classes 'SequentialFutureBackend', 'FutureBackend', 'environment' <environment: 0x5726f964b880> 
[14:30:48.972] | : . ' , ; ` | : . '   .. ..- attr(*, "factory")=function (..., maxSizeOfObjects = +Inf)  
[14:30:48.972] | : . ' , ; ` | : . '   .. .. ..- attr(*, "tweakable")= chr [1:5] "maxSizeOfObjects" "earlySignal" "gc" "interrupts" ...
[14:30:48.972] | : . ' , ; ` | : . '  - attr(*, "class")= chr [1:2] "FutureStrategyList" "list"
[14:30:48.979] | : . ' , ; ` | : . ' Identical
[14:30:48.979] | : . ' , ; ` | : . all.equal() for FutureStrategyList ... done
[14:30:48.979] | : . ' , ; ` | : . plan(): Skip setting new future backend stack because it is the same as the current one:
[14:30:48.979] | : . ' , ; ` | : . List of future strategies:
[14:30:48.979] | : . ' , ; ` | : . 1. sequential:
[14:30:48.979] | : . ' , ; ` | : .    - args: function (..., envir = parent.frame(), workers = "<NULL>")
[14:30:48.979] | : . ' , ; ` | : .    - tweaked: FALSE
[14:30:48.979] | : . ' , ; ` | : .    - call: future::plan(future::sequential)
[14:30:48.980] | : . ' , ; ` | : plan(): plan_set(<1 strategies>, skip = FALSE, cleanup = FALSE, init = FALSE) ... done
[14:30:48.980] | : . ' , ; ` | plan(<‘FutureStrategyList’>, .skip = FALSE, .cleanup = FALSE, .init = FALSE) ... done
[14:30:48.981] | : . ' , ; ` plan(<‘name’>, .skip = FALSE, .cleanup = FALSE, .init = FALSE) ... done
[14:30:48.981] | : . ' , ; ` SequentialFuture started (and completed)
[14:30:48.981] | : . ' , ; ` signalConditions() ...
[14:30:48.981] | : . ' , ; ` | include = ‘immediateCondition’
[14:30:48.984] | : . ' , ; ` | exclude = 
[14:30:48.984] | : . ' , ; ` | resignal = FALSE
[14:30:48.984] | : . ' , ; ` | Number of conditions: 16
[14:30:48.984] | : . ' , ; ` |  int 16
[14:30:48.985] | : . ' , ; ` | Condition #1 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.985] | : . ' , ; ` | Condition #2 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.985] | : . ' , ; ` | Condition #3 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.985] | : . ' , ; ` | Condition #4 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.986] | : . ' , ; ` | Condition #5 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.986] | : . ' , ; ` | Condition #6 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.986] | : . ' , ; ` | Condition #7 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.986] | : . ' , ; ` | Condition #8 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.986] | : . ' , ; ` | Condition #9 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.986] | : . ' , ; ` | Condition #10 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.986] | : . ' , ; ` | Condition #11 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.986] | : . ' , ; ` | Condition #12 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.987] | : . ' , ; ` | Condition #13 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.987] | : . ' , ; ` | Condition #14 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.987] | : . ' , ; ` | Condition #15 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.987] | : . ' , ; ` | Condition #16 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.987] | : . ' , ; ` | Drop signaled conditions: 0
[14:30:48.987] | : . ' , ; ` signalConditions() ... done
[14:30:48.987] | : . ' , ; launchFuture() for ‘SequentialFutureBackend’, ‘FutureBackend’, ‘environment’ ... done
[14:30:48.988] | : . ' , Launching futures ... done
[14:30:48.988] | : . ' , Future launched: ‘SequentialFuture’, ‘UniprocessFuture’, ‘Future’
[14:30:48.988] | : . ' Using SequentialFutureBackend ... done
[14:30:48.988] | : . run() for ‘Future’ (‘future_lapply-1’) ... done
[14:30:48.988] | : future(..., label = ‘future_lapply-1’) ... done
[14:30:48.989] | : Created future:
[14:30:48.989] | : SequentialFuture:
[14:30:48.989] | : Label: ‘future_lapply-1’
[14:30:48.989] | : Expression:
[14:30:48.989] | : {
[14:30:48.989] | :     "# future::getGlobalsAndPackages(): wrapping the original future"
[14:30:48.989] | :     "# expression in do.call(), because function called uses '...'  "
[14:30:48.989] | :     "# as a global variable                                         "
[14:30:48.989] | :     do.call(function(...) {
[14:30:48.989] | :         "# future::getGlobalsAndPackages(): FUN() uses '...' internally "
[14:30:48.989] | :         "# without having an '...' argument. This means '...' is treated"
[14:30:48.989] | :         "# as a global variable. This may happen when FUN() is an       "
[14:30:48.989] | :         "# anonymous function.                                          "
[14:30:48.989] | :         "#                                                              "
[14:30:48.989] | :         "# If an anonymous function, we will make sure to restore the   "
[14:30:48.989] | :         "# function environment of FUN() to the calling environment.    "
[14:30:48.989] | :         "# We assume FUN() an anonymous function if it lives in the     "
[14:30:48.989] | :         "# global environment, which is where globals are written.      "
[14:30:48.989] | :         penv <- env <- environment(...future.FUN)
[14:30:48.989] | :         repeat {
[14:30:48.989] | :             if (identical(env, globalenv()) || identical(env, 
[14:30:48.989] | :                 emptyenv())) 
[14:30:48.989] | :                 break
[14:30:48.989] | :             penv <- env
[14:30:48.989] | :             env <- parent.env(env)
[14:30:48.989] | :         }
[14:30:48.989] | :         if (identical(penv, globalenv())) {
[14:30:48.989] | :             environment(...future.FUN) <- environment()
[14:30:48.989] | :         }
[14:30:48.989] | :         else if (!identical(penv, emptyenv()) && !is.null(penv) && 
[14:30:48.989] | :             !isNamespace(penv)) {
[14:30:48.989] | :             parent.env(penv) <- environment()
[14:30:48.989] | :         }
[14:30:48.989] | :         rm(list = c("env", "penv"), inherits = FALSE)
[14:30:48.989] | :         {
[14:30:48.989] | :             "# future.apply:::future_xapply(): preserve future option"
[14:30:48.989] | :             ...future.globals.maxSize.org <- getOption("future.globals.maxSize")
[14:30:48.989] | :             if (!identical(...future.globals.maxSize.org, ...future.globals.maxSize)) {
[14:30:48.989] | :                 oopts <- options(future.globals.maxSize = ...future.globals.maxSize)
[14:30:48.989] | :                 on.exit(options(oopts), add = TRUE)
[14:30:48.989] | :             }
[14:30:48.989] | :             {
[14:30:48.989] | :                 "# future.apply::future_lapply(): process chunk of elements"
[14:30:48.989] | :                 lapply(seq_along(...future.elements_ii), FUN = function(jj) {
[14:30:48.989] | :                   ...future.X_jj <- ...future.elements_ii[[jj]]
[14:30:48.989] | :                   {
[14:30:48.989] | :                     ...future.FUN(...future.X_jj, ...)
[14:30:48.989] | :                   }
[14:30:48.989] | :                 })
[14:30:48.989] | :             }
[14:30:48.989] | :         }
[14:30:48.989] | :     }, args = future.call.arguments)
[14:30:48.989] | : }
[14:30:48.989] | : Globals: 5 objects totaling 5.42 KiB (function ‘...future.FUN’ of 1.24 KiB, list ‘...future.elements_ii’ of 151 bytes, DotDotDotList ‘future.call.arguments’ of 97 bytes, NULL ‘...future.seeds_ii’ of 27 bytes, NULL ‘...future.globals.maxSize’ of 27 bytes)
[14:30:48.989] | : Packages: <none>
[14:30:48.989] | : L'Ecuyer-CMRG RNG seed: <none> (seed = FALSE)
[14:30:48.989] | : Capture standard output: NA
[14:30:48.989] | : Capture condition classes: ‘condition’ (excluding ‘<none>’)
[14:30:48.989] | : Immediate condition classes: ‘immediateCondition’
[14:30:48.989] | : Lazy evaluation: FALSE
[14:30:48.989] | : Local evaluation: TRUE
[14:30:48.989] | : Asynchronous evaluation: TRUE
[14:30:48.989] | : Early signaling: FALSE
[14:30:48.989] | : Environment: R_GlobalEnv
[14:30:48.989] | : State: ‘finished’
[14:30:48.989] | : Resolved: TRUE
[14:30:48.989] | : Unique identifier: e61829d9b25b3546ee20649bd6d0e02d-8
[14:30:48.989] | : Owner process: e61829d9b25b3546ee20649bd6d0e02d
[14:30:48.989] | : Class: ‘SequentialFuture’, ‘UniprocessFuture’, ‘Future’
[14:30:48.989] | : Value: 71 bytes of class ‘list’
[14:30:48.989] | : Conditions captured: [n=16] ‘simpleMessage’, ‘simpleMessage’, ‘simpleMessage’, ‘simpleMessage’, ‘simpleMessage’, ‘simpleMessage’, ‘rlang_message’, ‘rlang_message’, ‘rlang_message’, ‘rlang_message’, ‘rlang_message’, ‘rlang_message’, ‘rlang_message’, ‘rlang_message’, ‘rlang_message’, ‘rlang_message’
[14:30:48.989] | : Duration: 10.35943 secs (started 2025-10-21 14:30:38.604404)
[14:30:48.989] | : Worker process: e61829d9b25b3546ee20649bd6d0e02d
[14:30:48.992] | : Chunk #1 of 1 ... DONE
[14:30:48.992] | : Launching 1 futures (chunks) ... DONE
[14:30:48.992] | : Resolving 1 futures (chunks) ...
[14:30:48.993] | : value() for list ...
[14:30:48.993] | : . recursive: 0
[14:30:48.993] | : . reduce: FALSE
[14:30:48.993] | : . length: 1

[14:30:48.993] | : . Number of remaining objects: 1
[14:30:48.993] | : . checking value #1:
[14:30:48.993] | : . 'obj' is SequentialFuture
[14:30:48.993] | : . resolved() ...
[14:30:48.994] | : . ' resolved() for SequentialFuture (‘future_lapply-1’) ...
[14:30:48.994] | : . ' , state: ‘finished’
[14:30:48.994] | : . ' , run: TRUE
[14:30:48.994] | : . ' , result: ‘FutureResult’
[14:30:48.994] | : . ' resolved() for SequentialFuture (‘future_lapply-1’) ... done
[14:30:48.994] | : . resolved() ... done
[14:30:48.994] | : . SequentialFuture #1
[14:30:48.994] | : . signalConditionsASAP(SequentialFuture, pos=1) ...
[14:30:48.995] | : . ' nx: 1
[14:30:48.995] | : . ' relay: TRUE
[14:30:48.995] | : . ' stdout: TRUE
[14:30:48.995] | : . ' signal: TRUE
[14:30:48.995] | : . ' resignal: FALSE
[14:30:48.995] | : . ' force: TRUE
[14:30:48.995] | : . ' relayed: [n=1] FALSE
[14:30:48.995] | : . ' queued futures: [n=1] FALSE
[14:30:48.995] | : . ' until=1
[14:30:48.995] | : . ' relaying element #1
[14:30:48.996] | : . ' value() for SequentialFuture (‘future_lapply-1’) ...
[14:30:48.996] | : . ' , signalConditions() ...
[14:30:48.996] | : . ' , ; include = ‘immediateCondition’
[14:30:48.996] | : . ' , ; exclude = 
[14:30:48.996] | : . ' , ; resignal = FALSE
[14:30:48.996] | : . ' , ; Number of conditions: 16
[14:30:48.996] | : . ' , ;  int 16
[14:30:48.997] | : . ' , ; Condition #1 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.997] | : . ' , ; Condition #2 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.997] | : . ' , ; Condition #3 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.997] | : . ' , ; Condition #4 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.997] | : . ' , ; Condition #5 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.998] | : . ' , ; Condition #6 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:48.998] | : . ' , ; Condition #7 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.998] | : . ' , ; Condition #8 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.998] | : . ' , ; Condition #9 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.998] | : . ' , ; Condition #10 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.998] | : . ' , ; Condition #11 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.998] | : . ' , ; Condition #12 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.998] | : . ' , ; Condition #13 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.998] | : . ' , ; Condition #14 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.999] | : . ' , ; Condition #15 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.999] | : . ' , ; Condition #16 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:48.999] | : . ' , ; Drop signaled conditions: 0
[14:30:48.999] | : . ' , signalConditions() ... done
[14:30:48.999] | : . ' , relay stdout ...
[14:30:48.999] | : . ' , relay stdout ... done
[14:30:48.999] | : . ' , check for misuse ...
[14:30:48.999] | : . ' , check for misuse ... done
[14:30:49.000] | : . ' value() for SequentialFuture (‘future_lapply-1’) ... done
[14:30:49.000] | : . ' signalConditions() ...
[14:30:49.000] | : . ' , include = ‘immediateCondition’
[14:30:49.000] | : . ' , exclude = 
[14:30:49.000] | : . ' , resignal = FALSE
[14:30:49.000] | : . ' , Number of conditions: 16
[14:30:49.000] | : . ' ,  int 16
[14:30:49.001] | : . ' , Condition #1 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.001] | : . ' , Condition #2 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.001] | : . ' , Condition #3 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.001] | : . ' , Condition #4 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.001] | : . ' , Condition #5 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.001] | : . ' , Condition #6 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.001] | : . ' , Condition #7 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.002] | : . ' , Condition #8 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.002] | : . ' , Condition #9 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.002] | : . ' , Condition #10 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.002] | : . ' , Condition #11 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.002] | : . ' , Condition #12 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.003] | : . ' , Condition #13 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.003] | : . ' , Condition #14 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.003] | : . ' , Condition #15 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.003] | : . ' , Condition #16 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.003] | : . ' , Drop signaled conditions: 0
[14:30:49.003] | : . ' signalConditions() ... done
[14:30:49.003] | : . ' signalConditions() ...
[14:30:49.004] | : . ' , include = ‘condition’
[14:30:49.004] | : . ' , exclude = ‘error’, ‘immediateCondition’
[14:30:49.004] | : . ' , resignal = TRUE
[14:30:49.004] | : . ' , Number of conditions: 16
[14:30:49.004] | : . ' ,  int 16
[14:30:49.005] | : . ' , Condition #1 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.005] | : . ' , Condition #1: ‘simpleMessage’, ‘message’, ‘condition’
[14:30:38.604] | : . ' , ; ` attachPackages() ...
[14:30:49.005] | : . ' , Condition #2 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.005] | : . ' , Condition #2: ‘simpleMessage’, ‘message’, ‘condition’
[14:30:38.604] | : . ' , ; ` | packages: [n=1] ‘future’
[14:30:49.005] | : . ' , Condition #3 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.006] | : . ' , Condition #3: ‘simpleMessage’, ‘message’, ‘condition’
[14:30:38.604] | : . ' , ; ` attachPackages() ... done
[14:30:49.006] | : . ' , Condition #4 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.006] | : . ' , Condition #4: ‘simpleMessage’, ‘message’, ‘condition’
[14:30:38.604] | : . ' , ; ` attachPackages() ...
[14:30:49.006] | : . ' , Condition #5 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.006] | : . ' , Condition #5: ‘simpleMessage’, ‘message’, ‘condition’
[14:30:38.605] | : . ' , ; ` | packages: [n=0] 
[14:30:49.006] | : . ' , Condition #6 (class: ‘simpleMessage’, ‘message’, ‘condition’):
[14:30:49.006] | : . ' , Condition #6: ‘simpleMessage’, ‘message’, ‘condition’
[14:30:38.605] | : . ' , ; ` attachPackages() ... done
[14:30:49.007] | : . ' , Condition #7 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.007] | : . ' , Condition #7: ‘rlang_message’, ‘message’, ‘condition’
hi[14:30:49.007] | : . ' , Condition #8 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.007] | : . ' , Condition #8: ‘rlang_message’, ‘message’, ‘condition’
hi[14:30:49.007] | : . ' , Condition #9 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.008] | : . ' , Condition #9: ‘rlang_message’, ‘message’, ‘condition’
hi[14:30:49.008] | : . ' , Condition #10 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.008] | : . ' , Condition #10: ‘rlang_message’, ‘message’, ‘condition’
hi[14:30:49.008] | : . ' , Condition #11 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.008] | : . ' , Condition #11: ‘rlang_message’, ‘message’, ‘condition’
hi[14:30:49.009] | : . ' , Condition #12 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.009] | : . ' , Condition #12: ‘rlang_message’, ‘message’, ‘condition’
hi[14:30:49.009] | : . ' , Condition #13 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.009] | : . ' , Condition #13: ‘rlang_message’, ‘message’, ‘condition’
hi[14:30:49.009] | : . ' , Condition #14 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.009] | : . ' , Condition #14: ‘rlang_message’, ‘message’, ‘condition’
hi[14:30:49.010] | : . ' , Condition #15 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.010] | : . ' , Condition #15: ‘rlang_message’, ‘message’, ‘condition’
hi[14:30:49.010] | : . ' , Condition #16 (class: ‘rlang_message’, ‘message’, ‘condition’):
[14:30:49.010] | : . ' , Condition #16: ‘rlang_message’, ‘message’, ‘condition’
hi[14:30:49.011] | : . ' , Drop signaled conditions: 16
[14:30:49.011] | : . ' signalConditions() ... done
[14:30:49.011] | : . ' relayed: [n=1] TRUE
[14:30:49.011] | : . ' queued futures: [n=1] TRUE
[14:30:49.011] | : . signalConditionsASAP(SequentialFuture, pos=1) ... done
[14:30:49.011] | : . value(<SequentialFuture>, ...) ...
[14:30:49.011] | : . value(<SequentialFuture>, ...) ... done
[14:30:49.011] | : . value() for SequentialFuture (‘future_lapply-1’) ...
[14:30:49.011] | : . ' signalConditions() ...
[14:30:49.012] | : . ' , include = ‘immediateCondition’
[14:30:49.012] | : . ' , exclude = 
[14:30:49.012] | : . ' , resignal = FALSE
[14:30:49.012] | : . ' , Number of conditions: 0
[14:30:49.012] | : . ' ,  int 0
[14:30:49.013] | : . ' signalConditions() ... done
[14:30:49.013] | : . ' check for misuse ...
[14:30:49.013] | : . ' check for misuse ... done
[14:30:49.013] | : . value() for SequentialFuture (‘future_lapply-1’) ... done
[14:30:49.013] | : . value: <list>
[14:30:49.013] | : . signalConditionsASAP(SequentialFuture, pos=1) ...
[14:30:49.013] | : . ' nx: 1
[14:30:49.013] | : . ' relay: TRUE
[14:30:49.014] | : . ' stdout: TRUE
[14:30:49.014] | : . ' signal: TRUE
[14:30:49.014] | : . ' resignal: FALSE
[14:30:49.014] | : . ' force: TRUE
[14:30:49.014] | : . ' relayed: [n=1] TRUE
[14:30:49.014] | : . ' queued futures: [n=1] TRUE
[14:30:49.014] | : . ' until=1
[14:30:49.014] | : . ' relayed: [n=1] TRUE
[14:30:49.014] | : . ' queued futures: [n=1] TRUE
[14:30:49.014] | : . signalConditionsASAP(SequentialFuture, pos=1) ... done
[14:30:49.015] | : . resolve() for SequentialFuture ...
[14:30:49.015] | : . resolve() for SequentialFuture ... done
[14:30:49.015] | : . length: 0 (resolved future 1)
[14:30:49.015] | : value() for list ... done
[14:30:49.015] | : Relaying remaining futures ...
[14:30:49.015] | : . signalConditionsASAP(NULL, pos=0) ...
[14:30:49.015] | : . ' nx: 1
[14:30:49.015] | : . ' relay: TRUE
[14:30:49.015] | : . ' stdout: TRUE
[14:30:49.016] | : . ' signal: TRUE
[14:30:49.016] | : . ' resignal: FALSE
[14:30:49.016] | : . ' force: TRUE
[14:30:49.016] | : . ' relayed: [n=1] TRUE
[14:30:49.016] | : . ' queued futures: [n=1] TRUE
 - flush all
[14:30:49.016] | : . ' relayed: [n=1] TRUE
[14:30:49.016] | : . ' queued futures: [n=1] TRUE
[14:30:49.016] | : . signalConditionsASAP(NULL, pos=0) ... done
[14:30:49.016] | : Relaying remaining futures ... done
[14:30:49.017] | future_lapply() -> future_xapply() ... done
[14:30:49.017] |  - Number of value chunks collected: 1
[14:30:49.017] | Resolving 1 futures (chunks) ... DONE
[14:30:49.017] | Reducing values from 1 chunks ...
[14:30:49.017] |  - Number of values collected after concatenation: 10
[14:30:49.017] |  - Number of values expected: 10
[14:30:49.017] | Reducing values from 1 chunks ... DONE
[14:30:49.017] future_lapply() ... done