如何在multidplyr中设置超时

Question

在使用multidplyr时，我不一致地得到以下错误(例如，对于相同的数据，有时我会得到错误，有时不会)：

rs_init中的错误(自、私有、超级、选项、等待、wait_timeout)：无法启动R会话，超时

我的背景看起来是：

list1 <- list() 

for (i in 1:500){
  while(TRUE){
    test1 <- try(df %>% 
                   group_by(id) %>% 
                   recursive_func_c())
    if(!is(test1, 'try-error')) break
  }
  list1[[i]] <- test1
}

其中recursive_func_c是一个调用以下函数的函数：

cluster <- multidplyr::new_cluster(7)

据我正确理解，多cluster集群由callr创建的多个R进程组成。我得到的错误消息似乎来自callr包。为了调试，我想为callr在multidplyr中设置一个更长的超时时间。这有可能吗？谢谢你的暗示。

Answer 1

认为这个问题在这里已经解决了：https://github.com/tidyverse/multidplyr/issues/97

15秒对我的设定来说可能太短了。

如果您面临同样的问题，您可以尝试用wait_timeout临时更改new_cluster()的trace(new_cluster, edit=TRUE) (更多关于通用函数修改的信息，请在这里找到：Modify package function)

60秒似乎对我有用。