Merge branch 'release/0.10.2'

Author: HenrikBengtsson

DESCRIPTION

@@ -1,5 +1,5 @@
 Package: future.callr
-Version: 0.10.1
+Version: 0.10.2
 Depends:
     R (>= 3.4.0),
     future (>= 1.58.0)
@@ -26,5 +26,5 @@ URL: https://future.callr.futureverse.org, https://github.com/futureverse/future
 BugReports: https://github.com/futureverse/future.callr/issues
 Language: en-US
 Encoding: UTF-8
-RoxygenNote: 7.3.2
+RoxygenNote: 7.3.3
 Roxygen: list(markdown = TRUE)

NEWS.md

@@ -1,3 +1,18 @@
+# Version 0.10.2 [2025-10-10]
+
+## Bug Fixes
+
+ * The 'callr' backend was holding on to temporary **callr** files
+   longer than necessary. Such files were only removed when the future
+   object itself was removed. This would result in a large number of
+   temporary files accumulating where there were many futures
+   processed. Now the 'callr' backend finalizes the 'callr' process as
+   soon as the future results have been collected, which results in
+   removing temporary files created by **callr** sooner. Previously,
+   the finalizer was only run when the future object was removed and
+   garbage collected.
+   
+
 # Version 0.10.1 [2025-07-10]
 
 ## Bug Fixes

R/CallrFutureBackend-class.R

@@ -48,7 +48,11 @@ launchFuture.CallrFutureBackend <- local({
   ## MEMOIZATION
   evalFuture <- import_future("evalFuture")
   getFutureData <- import_future("getFutureData")
-  with_stealth_rng <- import_future("with_stealth_rng")
+  with_stealth_rng <- if (packageVersion("processx") >= "3.8.6") {
+    identity
+  } else {
+    import_future("with_stealth_rng")
+  }
 
   cmdargs <- NULL
 
@@ -126,7 +130,8 @@ launchFuture.CallrFutureBackend <- local({
 
 
     ## Launch
-    ## WORKAROUND: callr::r_bg() updates the RNG state
+    ## WORKAROUND: callr::r_bg() -> ... -> processx:::get_id() updates
+    ## the RNG state. This was fixed in processx 3.8.6 (2025-02-21).
     with_stealth_rng({
       future[["process"]] <- r_bg(func, args = r_bg_args, stdout = stdout, stderr = stderr, cmdargs = cmdargs, supervise = supervise)
     })
@@ -456,6 +461,10 @@ await <- function(future, ...) {
       if (FutureRegistry(reg, action = "contains", future = future)) {
         FutureRegistry(reg, action = "remove", future = future)
       }
+      
+      ## Finalize the 'callr' process, which includes remove any temporary
+      ## files that it created
+      process$finalize()
     }
 
     ## Failed to launch?
@@ -526,6 +535,10 @@ await <- function(future, ...) {
 
   reg <- backend[["reg"]]
   FutureRegistry(reg, action = "remove", future = future)
+
+  ## Finalize the 'callr' process, which includes remove any temporary
+  ## files that it created
+  process$finalize()
 
   result
 } # await()

R/package.R

@@ -5,11 +5,13 @@
 #' The Future API is defined by the \pkg{future} package.
 #'
 #' To use callr futures, load \pkg{future.callr}, and
-#' select the type of future you wish to use, e.g. `plan(callr)`.
+#' select the type of future you wish to use, e.g.
+#' `plan(future.callr::callr)`.
 #'
 #' @examples
 #' \donttest{
-#' plan(callr)
+#' library(future)
+#' plan(future.callr::callr)
 #' demo("mandelbrot", package = "future", ask = FALSE)
 #' }
 #'

README.md

@@ -21,8 +21,8 @@ utilizes the **[callr]** package.
 For example,
 
 ```r
-> library(future.callr)
-> plan(callr)
+> library(future)
+> plan(future.callr::callr)
 >
 > x %<-% { Sys.sleep(5); 3.14 }
 > y %<-% { Sys.sleep(5); 2.71 }
@@ -108,8 +108,8 @@ futures are evaluated_.  For instance, to use `callr` futures, run the
 demo as:
 
 ```r
-library(future.callr)
-plan(callr)
+library(future)
+plan(future.callr::callr)
 demo("mandelbrot", package = "future", ask = FALSE)
 ```
 

inst/WORDLIST

@@ -26,6 +26,7 @@ callr
 cran
 doFuture
 doi
+finalizer
 finalizers
 furrr
 github

inst/testme/test-callr,launch-failure.R

@@ -1,4 +1,4 @@
-library(future.callr)
+library(future)
 library(listenv)
 
 options(future.debug = FALSE)
@@ -7,7 +7,7 @@ message("*** callr() ...")
 
 message("- Error in ./.Rprofile causes callr process to fail")
 
-plan(callr, workers = 2L)
+plan(future.callr::callr, workers = 2L)
 
 ## STRICTER TEST: Assert that FutureRegistry won't trigger errors
 for (kk in seq_len(nbrOfWorkers())) {

inst/testme/test-callr,worker-termination.R

@@ -1,8 +1,8 @@
-library(future.callr)
+library(future)
 
 message("*** callr() - terminating workers ...")
 
-plan(callr, workers = 2L)
+plan(future.callr::callr, workers = 2L)
 
 all <- nbrOfWorkers()
 free <- nbrOfFreeWorkers()

inst/testme/test-demo.R

@@ -1,4 +1,4 @@
-library(future.callr)
+library(future)
 
 options(future.demo.mandelbrot.nrow = 2L)
 options(future.demo.mandelbrot.resolution = 50L)
@@ -8,7 +8,7 @@ message("*** Demos ...")
 
 message("*** Mandelbrot demo of the 'future' package ...")
 
-plan(callr)
+plan(future.callr::callr)
 demo("mandelbrot", package = "future", ask = FALSE)
 
 message("*** Demos ... DONE")

inst/testme/test-dotdotdot.R

@@ -1,3 +1,4 @@
+library(future)
 library(future.callr)
 library(listenv)