Merge branch 'release/1.58.0'

Author: HenrikBengtsson

.github/workflows/R-CMD-check.yaml

@@ -38,7 +38,6 @@ jobs:
           - {os: ubuntu-latest,  r: 'release'  , language: ko,    label: ko    }
           - {os: ubuntu-latest,  r: 'release'  , language: zh_CN, label: zh_CN }
           - {os: ubuntu-latest,  r: 'release'  , language: zh_TW, label: zh_TW }
-          - {os: ubuntu-latest,  r: 'release'  , globals_keepWhere: true, label: 'keepWhere' }
           - {os: ubuntu-latest,  r: 'release'  , globals_keepWhere: false, label: '!keepWhere' }
           - {os: ubuntu-latest,  r: 'release'  , plan: multicore, fork_multithreading_enable: false, label: 'multicore, no-multithreading-in-forks' }
           - {os: ubuntu-latest,  r: 'release'  , plan: multisession, fork_multithreading_enable: false, label: 'multisession, no-multithreading-in-forks' }

.github/workflows/revdepcheck-top.yaml

@@ -21,19 +21,21 @@ jobs:
           - { r: "release", pkg: "future.mirai"      }
           - { r: "release", pkg: "doFuture"          }
           - { r: "release", pkg: "future.apply"      }
-          - { r: "release", pkg: "furrr"             }
+          - { r: "release", pkg: "furrr", not_cran: false }
           - { r: "release", pkg: "future.tests"      }
+          - { r: "release", pkg: "promises"          }
+          - { r: "release", pkg: "shiny", not_cran: false }
+          - { r: "release", pkg: "plumber"           }
           - { r: "release", pkg: "future.batchtools" , globals: develop, label: 'globals develop' }
           - { r: "release", pkg: "future.callr"      , globals: develop, label: 'globals develop' }
           - { r: "release", pkg: "future.mirai"      , globals: develop, label: 'globals develop' }
           - { r: "release", pkg: "doFuture"          , globals: develop, label: 'globals develop' }
           - { r: "release", pkg: "future.apply"      , globals: develop, label: 'globals develop' }
-          - { r: "release", pkg: "furrr"             , globals: develop, label: 'globals develop' }
+          - { r: "release", pkg: "furrr", not_cran: false, globals: develop, label: 'globals develop' }
           - { r: "release", pkg: "future.tests"      , globals: develop, label: 'globals develop' }
           - { r: "release", pkg: "doFuture"          , plan: multisession, label: multisession }
           - { r: "release", pkg: "future.apply"      , plan: multisession, label: multisession }
-          - { r: "release", pkg: "furrr"             , plan: multisession, label: multisession }
-          - { r: "release", pkg: "future.apply"      , globals_keepWhere: true, label: 'keepWhere' }
+          - { r: "release", pkg: "furrr", not_cran: false, plan: multisession, label: multisession }
           - { r: "release", pkg: "future.apply"      , globals_keepWhere: false, label: '!keepWhere' }
 
     env:
@@ -47,8 +49,7 @@ jobs:
       R_FUTURE_PLAN: ${{ matrix.config.plan }}
       R_FUTURE_GLOBALS_KEEPWHERE: ${{ matrix.config.globals_keepWhere }}
       R_GLOBALS_BRANCH: ${{ matrix.config.globals }}
-      ## Specific to furrr (to disable expect_snapshot() tests)
-      NOT_CRAN: false
+      NOT_CRAN: true
 
     steps:
       - uses: actions/checkout@v4
@@ -91,6 +92,10 @@ jobs:
         run: |
           url=$(Rscript -e "cat(remotes:::download_version_url('${{ matrix.config.pkg }}', version=NULL, repos='https://cloud.r-project.org', type='source'))")
           wget "$url"
+          if [[ "${{ matrix.config.not_cran }}" == "false" ]]; then
+            export NOT_CRAN=false
+          fi
+          echo "NOT_CRAN=${NOT_CRAN:-<not set>}"
           R CMD check --no-manual --as-cran "$(basename "$url")"
 
       - name: Upload check results

DESCRIPTION

@@ -1,5 +1,5 @@
 Package: future
-Version: 1.49.0
+Version: 1.58.0
 Title: Unified Parallel and Distributed Processing in R for Everyone
 Depends:
     R (>= 3.2.0)

NAMESPACE

@@ -1,8 +1,10 @@
 # Generated by roxygen2: do not edit by hand
 
 S3method("$<-",Future)
+S3method("[",FutureCluster)
 S3method("[",FutureGlobals)
 S3method("[",sessionDetails)
+S3method("[[",FutureCluster)
 S3method(all.equal,FutureStrategyList)
 S3method(all.equal,future)
 S3method(as.FutureGlobals,FutureGlobals)
@@ -127,6 +129,9 @@ export(ClusterFutureBackend)
 export(ConnectionMisuseFutureCondition)
 export(ConnectionMisuseFutureError)
 export(ConnectionMisuseFutureWarning)
+export(DefaultDeviceMisuseFutureCondition)
+export(DefaultDeviceMisuseFutureError)
+export(DefaultDeviceMisuseFutureWarning)
 export(DeviceMisuseFutureCondition)
 export(DeviceMisuseFutureError)
 export(DeviceMisuseFutureWarning)
@@ -196,6 +201,13 @@ export(supportsMulticore)
 export(tweak)
 export(validateFutureGlobals)
 export(value)
+if (getRversion() >= "4.4") S3method(print,FutureCluster)
+if (getRversion() >= "4.4") S3method(recvData,FutureNode)
+if (getRversion() >= "4.4") S3method(sendData,FutureNode)
+if (getRversion() >= "4.4") export(FUTURE)
+if (getRversion() >= "4.4") export(makeClusterFuture)
+if (getRversion() >= "4.4") importFrom(parallel,recvData)
+if (getRversion() >= "4.4") importFrom(parallel,sendData)
 importFrom(digest,digest)
 importFrom(globals,Globals)
 importFrom(globals,as.Globals)

NEWS.md

@@ -1,3 +1,79 @@
+# Version 1.58.0 [2025-06-05]
+
+This is the third rollout out of several towards a near-future major
+release that I am really excited about. This has been made possible
+due to a multi-year effort of internal re-designs, work with package
+maintainers, release, and repeat. This release fixes a few
+regressions introduced in future 1.40.0 (2025-04-10), despite passing
+[all unit, regression, and system
+tests](https://www.futureverse.org/quality.html).
+
+## New Features
+
+ * Now futures produce a warning when they detect that the _default_
+   graphics device, as defined by R option `"device"`, is opened by,
+   for instance, a `plot()` call without explicitly opening a graphics
+   device. The reason for this check is that we rarely want to plot to
+   the _default_ graphics device in parallel processing, which
+   typically ends up plotting to a `Rplots.pdf` file that is local to
+   the parallel worker. If that is truly wanted, please open a
+   graphics devices explicitly (e.g. `pdf()` or `png()`) before
+   plotting. Alternatively, explicitly set R option `device` inside
+   the future expression.
+
+## Beta Features
+
+ * Add `makeClusterFuture()` for creating a cluster of stateless
+   parallel workers for processing via the future framework. This
+   requires R (>= 4.4.0) [2024-04-24]. Please make sure to read
+   `help("makeClusterFuture", package = "future")` to learn about
+   potential pitfalls. The plan is to support more corner cases in
+   future releases, and when not possible, add more mechanisms for
+   detecting non-supported cases and given an informative error.
+
+## Bug Fixes
+
+ * Setting `options(warn = 2)` on a parallel worker was ignored -
+   warnings were not escalated to errors on the worker, and was
+   instead relayed as-is in the parent R session, unless `options(warn
+   = 2)` was also set in the parent. Now `options(warn = 2)` on a
+   worker causes warnings to be escalated immediately to errors on the
+   worker, which therefore also terminates the future.
+
+ * `future()` arguments `stdout` and `conditions` were not applied
+   when packages that were specified via argument `packages` were
+   loaded and attached. This prevented us from excluding, for
+   instance, `packageStartupMessage`:s, causing them to be displayed
+   in sequential and multicore processing.
+ 
+ * When the using `cluster` and `multisession` backends, one could, in
+   some cases, end up with warnings on "package may not be available
+   when loading" that are produced by `serialize()`. These type of
+   warnings are now suppressed.
+ 
+ * Now the cluster future backend tries even harder to shut down
+   parallel cluster workers when shutting down the backend. If it
+   fails to communicate with one or more of the parallel workers, it
+   will now close any socket connections that remain open towards such
+   cluster nodes.
+
+ * The built-in checks for added, removed, or modified graphical
+   devices introduced in **future** 1.40.0 (2025-04-10), could produce
+   false positives, complaining about "A future expression must close
+   any opened devices and must not close devices it did not
+   open. Details: 1 devices differ: index=2, before='NA',
+   after=''". The problem was that it did not prune the empty 'after'
+   before the check.
+
+ * The `multicore` backend did not relay `immediateCondition`:s in a
+   near-live fashion, but only when the results of the futures where
+   collected.
+
+ * The `sequential`, `cluster`, `multisession`, and `multicore`
+   backends relayed `immediateCondition`:s, but did not record them
+   properly in the future object.
+
+
 # Version 1.49.0 [2025-05-08]
 
 This is the second rollout out of three-four major updates, which is

R/backend_api-01-FutureBackend-class.R

@@ -1,5 +1,14 @@
 #' Configure a backend that controls how and where futures are evaluated
 #'
+#' @description
+#' _This functionality is only for developers who wish to implement their
+#' own future backend.  End-users and package developers use futureverse,
+#' does not need to know about these functions._
+#'
+#' If you are looking for available future backends to choose from, please
+#' see the 'A Future for R: Available Future Backends' vignette and
+#' \url{https://www.futureverse.org/backends.html}.
+#'
 #' @param \ldots (optional) Backend-specific named arguments.
 #'
 #' @param earlySignal Overrides the default behavior on whether futures
@@ -107,7 +116,7 @@ print.FutureBackend <- function(x, ...) {
   fields <- tweakable(attr(backend, "factory"))
   fields <- setdiff(fields, done)
   for (name in fields) {
-    s <- c(s, sprintf("Argument %s: %s", sQuote(name), deparse(backend[[name]])))
+    s <- c(s, sprintf("Argument %s: %s", sQuote(name), paste(deparse(backend[[name]]), collapse = "") ))
   }
 
   ## Active futures