logo标签列表

furrr找不到自己的软件包

rparallel-processingpackager-futurefurrr
6

我目前正在开发一个包，我们称之为myPack。 我有一个名为myFunc1的函数和另一个名为myFunc2的函数，大致如下：

myFunc2 <- function(x, parallel = FALSE) { 
if(parallel) future::plan(future::multiprocess)
values <- furrr::future_map(x, myFunc1)
values
}

如果我在非并行状态下调用myFunc2，它可以工作。但是如果我将parallel = TRUE作为参数调用它，则会出现以下错误：

Error: Unexpected result (of class ‘snow-try-error’ != ‘FutureResult’)
retrieved for MultisessionFuture future (label = ‘<none>’, expression = 
‘{; do.call(function(...) {; ...future.f.env <- environment(...future.f); 
if (!is.null(...future.f.env$`~`)) {; if 
(is_bad_rlang_tilde(...future.f.env$`~`)) {; ...future.f.env$`~` <- 
base::`~`; ...; }); }, args = future.call.arguments); }’): there is no 
package called 'myPack'. This suggests that the communication with 
MultisessionFuture worker (‘SOCKnode’ #1) is out of sync.

有人知道为什么myFunc2在顺序模式下运行正常，但并行模式下会出错，我该如何防止这个错误的出现吗？

可重现的示例：

linear_model_1 <- lm(mpg ~ cyl + disp + hp, data = mtcars)
linear_model_2 <- lm(mpg ~ cyl + poly(disp, 2), data = mtcars)
x <- list(linear_model_1, linear_model_2)


myFunc1 <- function(model, seed, size) {
  `%>%` <- purrr::`%>%`
  set.seed(seed)
  draws <- rep(size, 10) %>% 
    furrr::future_map(sample, x = fitted(model), replace = TRUE)
  mean(unlist(draws))
}

（注：这不是整个函数，但基本上可以用缩短版来解释）
(Note: 这不是整个函数，但基本上可以用缩短版来解释)
1
请提供一个简单的 x 和 myFunc1，以便重现您的问题。 - F. Privé
1
在原帖中添加了一个示例。 - user11143533
数据 x 仍然缺失... - Christoph
1
x 是模型列表。 - user11143533
我无法重现这个问题。在我的电脑上运行正常。 - Axeman
请提供一个可复制的示例。当前代码无法工作，例如seed和size没有在任何地方声明。 - HenrikB
1个回答
1
网页内容由stack overflow 提供, 点击上面的
可以查看英文原文，
原文链接