diff --git a/R/CallrFutureBackend-class.R b/R/CallrFutureBackend-class.R index 03845f5..6bb1199 100644 --- a/R/CallrFutureBackend-class.R +++ b/R/CallrFutureBackend-class.R @@ -464,7 +464,11 @@ await <- function(future, ...) { ## Finalize the 'callr' process, which includes remove any temporary ## files that it created - process$finalize() + if (is.function(process$cleanup)) { + process$cleanup() + } else { + process$finalize() + } } ## Failed to launch? @@ -538,8 +542,12 @@ await <- function(future, ...) { ## Finalize the 'callr' process, which includes remove any temporary ## files that it created - process$finalize() - + if (is.function(process$cleanup)) { + process$cleanup() + } else { + process$finalize() + } + result } # await()