You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Add generic function cloneNode() with implementation for RichSOCKnode, e.g.
library(parallelly)
cl<- makeClusterPSOCK(2L)
node<-cl[[2]]
node## node of a socket cluster on host 'localhost' with pid 1256882another_node<- cloneNode(node)
another_node## node of a socket cluster on host 'localhost' with pid 1256886cl<- c(cl, another_node)
This would make it possible to restart crashed workers, e.g.
for (kkin seq_along(cl)) {
node<-cl[[kk]]
if (!isNodeAlive(node)) {
node<- cloneNode(node)
cl[[kk]] <-node
}
}
For this to work, the RichSOCKnode object needs to record all details on how it was launched.
The text was updated successfully, but these errors were encountered:
Add generic function
cloneNode()
with implementation for RichSOCKnode, e.g.This would make it possible to restart crashed workers, e.g.
For this to work, the
RichSOCKnode
object needs to record all details on how it was launched.The text was updated successfully, but these errors were encountered: