furrr没有找到自己的包

Question

我目前正在开发一个包，比方说它叫做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))
}

(注意:这不是整个函数，但它基本上是它在缩短版本中所做的事情)

Answer 1

我在这里也遇到过同样的情况。您必须使用devtools: install ()至少安装一次包。这一点在这一期中有记录：https://github.com/DavisVaughan/furrr/issues/95