cluster,multisession: Suppress warning produced by serialize()

Author: HenrikBengtsson

DESCRIPTION

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

NEWS.md

@@ -23,12 +23,17 @@
    worker, which therefore also terminates the future.
 
  * `future()` arguments `stdout` and `conditions` were not applied
-   when packages that are specified via argument `packages` where
+   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.
 
- * Now the ClusterFutureBackend tries even harder to shut down
+ * 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

R/backend_api-11.ClusterFutureBackend-class.R

@@ -1095,7 +1095,9 @@ requestNode <- function(await, backend, timeout, delta, alpha) {
     okay <- TRUE
     truth <- "future:::requestNode() validation call"
     res <- tryCatch({
-      clusterCall(cl = cl, function(x) x, truth)[[1]]
+      suppressWarnings({
+        clusterCall(cl = cl, function(x) x, truth)[[1]]
+      })
     }, error = identity)
     ## If not working, investigate why, and relaunch a new worker
     if (inherits(res, "error") || !identical(res, truth)) {
@@ -1195,7 +1197,9 @@ node_call_nonblocking <- local({
 
   function(node, ..., when = "send call to", future) {
     tryCatch({
-      sendCall(node, ...)
+      suppressWarnings({
+        sendCall(node, ...)
+      })
     }, error = function(ex) {
       msg <- post_mortem_cluster_failure(ex, when = when, node = node, future = future)
       ex <- FutureError(msg, future = future)
@@ -1210,7 +1214,9 @@ cluster_call_blocking <- function(cl, ..., when = "call function on", future, ex
   stop_if_not(inherits(future, "Future"))
 
   ans <- tryCatch({
-    clusterCall(cl = cl, ...)
+    suppressWarnings({
+      clusterCall(cl = cl, ...)
+    })
   }, error = function(ex) {
     msg <- post_mortem_cluster_failure(ex, when = when, node = cl[[1]], future = future)
     ex <- FutureError(msg, future = future)