Merge branch 'release/1.20.1'

Author: HenrikBengtsson

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

@@ -22,7 +22,7 @@ jobs:
           - {os: macOS-latest,   r: 'devel'    }
           - {os: macOS-latest,   r: 'release'  }
           - {os: macOS-latest,   r: 'oldrel'   }
-#          - {os: ubuntu-latest,  r: 'devel'    }
+          - {os: ubuntu-latest,  r: 'devel', strict: true, label: 'strict' }
           - {os: ubuntu-latest,  r: 'release'  }
           - {os: ubuntu-latest,  r: 'oldrel'   }
           - {os: ubuntu-latest,  r: 'oldrel-1' }
@@ -31,9 +31,7 @@ jobs:
           - {os: ubuntu-latest,  r: 'release'  , language: ko,    label: ko    }
           - {os: ubuntu-latest,  r: 'release'  , globals_keepWhere: true, label: 'keepWhere' }
           - {os: ubuntu-latest,  r: 'release'  , globals_keepWhere: false, label: '!keepWhere' }
-          - {os: windows-latest, r: 'devel', globals_version: develop, future_version: develop, label: 'w/ future-develop' }
           - {os: windows-latest, r: 'devel', future_version: develop, label: 'w/ future-develop' }
-          - {os: ubuntu-latest,  r: 'release', globals_version: develop, future_version: develop, label: 'w/ future-develop' }
           - {os: ubuntu-latest,  r: 'release', future_version: develop, label: 'w/ future-develop' }
 
     env:
@@ -107,6 +105,16 @@ jobs:
 
       - name: Check
         run: |
+          if ("${{ matrix.config.strict }}" == "true") {
+            Sys.setenv(NOT_CRAN = "true")
+            Sys.setenv(R_FUTURE_GLOBALENV_ONMISUSE = "error")
+            Sys.setenv(R_FUTURE_RNG_ONMISUSE = "error")
+            Sys.setenv(R_FUTURE_FUTURE_EARLYSIGNAL = "defunct")
+            Sys.setenv(R_FUTURE_FUTURE_LOCAL = "defunct")
+            Sys.setenv(R_FUTURE_FUTURE_GC = "defunct")
+            Sys.setenv(R_FUTURE_PLAN_EARLYSIGNAL = "defunct")
+            Sys.setenv(R_FUTURE_RESOLVED_RUN = "defunct")
+          }
           if (nzchar(Sys.getenv("R_FUTURE_PLAN"))) Sys.setenv(RCMDCHECK_ERROR_ON = "error")
           rcmdcheck::rcmdcheck(
             args = c("--no-manual", "--as-cran"),

DESCRIPTION

@@ -1,5 +1,5 @@
 Package: future.apply
-Version: 1.20.0
+Version: 1.20.1
 Title: Apply Function to Elements in Parallel using Futures
 Depends:
     R (>= 3.2.0),
@@ -28,5 +28,5 @@ URL: https://future.apply.futureverse.org, https://github.com/futureverse/future
 BugReports: https://github.com/futureverse/future.apply/issues
 Language: en-US
 Encoding: UTF-8
-RoxygenNote: 7.3.2
+RoxygenNote: 7.3.3
 Roxygen: list(markdown = TRUE)

NEWS.md

@@ -1,3 +1,12 @@
+# Version 1.20.1 [2025-12-08]
+
+## Bug Fixes
+
+ * `future_apply(..., future.globals = list(...))` would produce
+   'Error in if (chunk_size > maxSize) { : missing value where
+   TRUE/FALSE needed'.
+ 
+
 # Version 1.20.0 [2025-06-06]
 
 ## Significant changes

R/future_apply.R

@@ -124,6 +124,8 @@ future_apply <- function(X, MARGIN, FUN, ..., simplify = TRUE, future.envir = pa
       nWorkers <- nbrOfWorkers()
       chunk_size <- size / nWorkers
       other_size <- attr(globals, "total_size")
+      ## Calculate size of the 'globals', if not already done
+      if (is.na(other_size)) other_size <- objectSize(X)
       if (is.numeric(other_size)) chunk_size <- chunk_size + other_size
       if (chunk_size > maxSize) {
         asIEC <- import_future("asIEC")

R/future_lapply.R

@@ -128,6 +128,27 @@
 #' reproducible given the same initial seed.
 #'
 #'
+#' @section Load balancing ("chunking"):
+#' Whether load balancing ("chunking") should take place or not can be
+#' controlled by specifying either argument
+#' `future.scheduling = <ratio>` or `future.chunk.size = <count>`.
+#'
+#' The value `future.chunk.size` specifies the average number of elements
+#' processed per future ("chunks").
+#' If `+Inf`, then all elements are processed in a single future (one worker).
+#' If `NULL`, then argument `future.scheduling` is used.
+#'
+#' The value `future.scheduling` specifies the average number of futures
+#' ("chunks") that each worker processes.
+#' If `0.0`, then a single future is used to process all iterations;
+#' none of the other workers are not used.
+#' If `1.0` or `TRUE`, then one future per worker is used.
+#' If `2.0`, then each worker will process two futures (if there are
+#' enough iterations).
+#' If `+Inf` or `FALSE`, then one future per iteration is used.
+#' The default value is `scheduling = 1.0`.
+#'
+#'
 #' @section Control processing order of elements:
 #' Attribute `ordering` of `future.chunk.size` or `future.scheduling` can
 #' be used to control the ordering the elements are iterated over, which
@@ -140,9 +161,10 @@
 #'                  `function(n) rev(seq_len(n))` for reverse ordering.
 #' * `"random"`   - this will randomize the ordering via random index
 #'                  vector `sample.int(length(X))`.
+#'
 #' For example, `future.scheduling = structure(TRUE, ordering = "random")`.
 #' _Note_, when elements are processed out of order, then captured standard
-#' output and conditions are also relayed in that order, that is out of order.
+#' output and conditions are relayed in that order as well.
 #'
 #' @example incl/future_lapply.R
 #'

R/future_xapply.R

@@ -1,4 +1,4 @@
-#' @importFrom future cancel Future nbrOfWorkers future resolve value as.FutureGlobals getGlobalsAndPackages FutureInterruptError
+#' @importFrom future cancel Future nbrOfWorkers future resolve value as.FutureGlobals getGlobalsAndPackages
 future_xapply <- local({
   tmpl_expr_options <- bquote_compile({
     "# future.apply:::future_xapply(): preserve future option"