Skip to content

Commit 8425ee7

Browse files
BUG FIX: Internal resolveMPI() was not updated to work with new the FutureBackend class [#805]
1 parent e847db8 commit 8425ee7

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
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.67.0-9001
2+
Version: 1.67.0-9003
33
Title: Unified Parallel and Distributed Processing in R for Everyone
44
Depends:
55
R (>= 3.2.0)

R/utils-basic.R

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -396,7 +396,12 @@ resolveMPI <- local({
396396
mpi.any.tag <- get("mpi.any.tag", mode = "function", envir = ns,
397397
inherits = FALSE)
398398
resolveMPI <- function(future) {
399-
node <- future[["workers"]][[future[["node"]]]]
399+
backend <- future[["backend"]]
400+
stopifnot(inherits(backend, "FutureBackend"))
401+
workers <- backend[["workers"]]
402+
stopifnot(inherits(workers, "cluster"))
403+
node <- workers[[future[["node"]]]]
404+
stopifnot(!is.null(node))
400405
mpi.iprobe(source = node[["rank"]], comm = node[["comm"]], tag = mpi.any.tag())
401406
}
402407
}

0 commit comments

Comments
 (0)