Skip to content

Commit 3bd80a1

Browse files
Avoid warning from resolved() on ClusterFuture with parallelly::makeClusterSequential() clusters
1 parent 9cff429 commit 3bd80a1

File tree

3 files changed

+6
-1
lines changed

3 files changed

+6
-1
lines changed

DESCRIPTION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
Package: future
2-
Version: 1.68.0-9034
2+
Version: 1.68.0-9035
33
Title: Unified Parallel and Distributed Processing in R for Everyone
44
Depends:
55
R (>= 3.2.0)

NEWS.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,9 @@
2626
1 unknown future arguments: 'interrupts'" for third-party future
2727
backends.
2828

29+
* `resolved()` on a 'cluster' future would produce a warning when
30+
using a `parallelly::makeClusterSequential())` cluster.
31+
2932
## Deprecated and Defunct
3033

3134
* The `cluster` backend now defaults to `earlySignal = FALSE`. This

R/backend_api-11.ClusterFutureBackend-class.R

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -725,6 +725,8 @@ resolved.ClusterFuture <- function(x, timeout = NULL, ...) {
725725
} ## while()
726726
} else if (inherits(node, "MPInode")) {
727727
res <- resolveMPI(future)
728+
} else if (inherits(node, "sequential_node")) {
729+
res <- TRUE
728730
} else {
729731
warnf("resolved() is not yet implemented for workers of class %s. Will use value() instead and return TRUE", sQuote(class(node)[1]))
730732
value(future, stdout = FALSE, signal = FALSE)

0 commit comments

Comments
 (0)