Preciso executar uma função que está no .GlobalEnv em um processamento paralelo utilizando o pacote multidplyr.
Utilizando um exemplo simples e sem processamento paralelo, funciona como esperado:
library(dplyr)
library(purrr)
library(multidplyr)
data.frame(x = 1:10) %>%
mutate(y = purrr::map(x, add_a))
Mas quando tento colocar o paralelismo, ele não reconhece a função "add_a"
add_a <- function(x) {
paste0(x, "A")
}
data.frame(x = 1:10) %>%
partition() %>%
mutate(
y = purrr::map(x, add_a)
)
Retornando a seguinte mensagem:
Error in checkForRemoteErrors(lapply(cl, recvResult)) :
10 nodes produced errors; first error: objeto 'add_a' não encontrado