Skip to content

Commit 7e034af

Browse files
Fix random warning on garbage collector closing connections when cancalling multisession futures - take 3 [#820]
1 parent cd47521 commit 7e034af

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-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.69.0-9007
2+
Version: 1.69.0-9008
33
Title: Unified Parallel and Distributed Processing in R for Everyone
44
Depends:
55
R (>= 3.2.0)

R/backend_api-11.ClusterFutureBackend-class.R

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1109,7 +1109,11 @@ requestNode <- local({
11091109
ex <- FutureError(msg, future = future)
11101110
stop(ex)
11111111
}
1112-
1112+
1113+
## Re-read workers from backend, because await() may have triggered
1114+
## handleInterruptedFuture(), which relaunches broken workers
1115+
workers <- backend[["workers"]]
1116+
11131117
## Find which node is available
11141118
avail <- rep(TRUE, times = length(workers))
11151119
futures <- FutureRegistry(reg, action = "list", earlySignal = FALSE, debug = debug)

0 commit comments

Comments
 (0)