Описание тега r-future

Вопросы с тегом
Используйте этот тег для вопросов, относящихся к будущей экосистеме в R - обычно используется для параллельной и асинхронной обработки. В основе этой экосистемы лежит Future API и будущий пакет, на котором затем будет построен более широкий набор пакетов.
0 ответов

FURRR на Tidygraph говорит: "Функция не должна вызываться напрямую"

Параллельные вычисления функций центральности тидиграфа с использованием furrr приводят к ошибке: "Ошибка в mutate_impl(.data, dots): Ошибка оценки: эту функцию нельзя вызывать напрямую". Вот мой код: library(tidyverse); library(tidygraph) H <- p…
17 фев '19 в 23:06
2 ответа

Почему фьючерсы второго уровня исполняются последовательно?

Я пытаюсь повторить примеры в топологии виньетки будущего пакета. Цитировать: Фьючерсы могут быть вложены в R так, что одно будущее создает другой набор фьючерсов и так далее. Это может происходить, например, в рамках вложенных циклов for [...] Есть…
11 июн '18 в 12:32
1 ответ

Как установить.libPaths (контрольную точку) на рабочих при выполнении параллельных вычислений в R

Я использую пакет контрольных точек для воспроизводимого анализа данных. Некоторые из вычислений занимают много времени, поэтому я хочу запустить их параллельно. Однако при параллельном запуске на рабочих местах контрольная точка не устанавливается,…
11 сен '18 в 12:35
0 ответов

Внутренняя функция пакета R не найдена при использовании foreach с контрольной точкой

Это дополнительный вопрос этого вопроса: Как установить.libPaths (контрольную точку) на рабочих при выполнении параллельных вычислений в R Основываясь на ответе, я поместил следующий код (упрощенный пример) в пакет R под названием "test1": #' @expor…
02 ноя '18 в 11:04
0 ответов

downloadHandler уникально игнорирует текущий асинхронный процесс для того же пользователя

Я экспериментировал с обещаниями, и, как я понимаю, как указано в этом выпуске, асинхронный процесс, выполняющийся для того же пользователя, должен блокировать выполнение всех других внутрисессионных действий. Однако это не кажется универсальным при…
23 окт '18 в 23:58
1 ответ

Будущее ждет исполнения на одноядерной машине

У меня есть 2 машины с идентичными версиями Ubuntu (16.04), R (3.4.4) и будущего пакета (1.10.0). Я запускаю код ниже, который реализует асинхронное программирование tic() library(future) plan(multisession) mehAsync = function(){ future::future({ Sy…
18 окт '18 в 00:35
1 ответ

Распараллелить несколько функций на одном объекте

Благодаря ДЭВИДУ ШОЧУ, я усилил его функцию и немного изменил, чтобы создать следующее. Работает отлично. Теперь все, что мне нужно, - это вычислить эти переменные, т.е. запустить функции на графическом объекте H параллельно, возможно, используя pur…
16 фев '19 в 20:23
1 ответ

Будущее ожидает завершения предыдущего будущего при отправке на удаленный

Я делаю следующее, чтобы отправить кучу моделей на вычислительный сервер. Будущее ожидает первого вызова для переноса, прежде чем следующий будет отправлен. Как я могу сообщить будущему, что он может отправлять несколько заданий одновременно на удал…
12 апр '18 в 12:19
0 ответов

Параллельная обработка в R зависает, когда не на мобильной точке доступа

У меня есть общая проблема с "параллелью" R-пакета, как показано здесь. Команда cl <- future::makeClusterPSOCK(1, outfile = NULL, verbose = TRUE) зависает на машине всякий раз, когда я подключаюсь к Wi-Fi-соединению. Тем не менее, он работает нор…
26 окт '18 в 07:22
0 ответов

Журнал R сообщений и ошибок при использовании future.batchtools

Раньше я имел возможность отслеживать задания на нашем вычислительном кластере Torque/PBS, просматривая файлы журналов задания. Я (или пакет, который я использую) должен был что-то изменить в какой-то момент, чтобы ошибки в задании больше не регистр…
30 янв '19 в 14:47
0 ответов

Будущее пакета R: инициализация плана () не удалась

Пробую этот код library(future) library(foreach) ncores <- 3 cl <- parallel::makeCluster(3) avail <- bigstatsr::FBM(ncores, 1, type = "integer", init = 1) doFuture::registerDoFuture() res <- vector("list", 5) for (i in seq_along(res)) { …
28 ноя '18 в 22:29
2 ответа

R параллельно makeCluster() бесконечно зависает на Mac

Я столкнулся с некоторой проблемой, когда я пытался использовать parallel пакет в R на моем Mac. Вот как работает параллельный пакет. cl = makeCluster(2) # Using 2-core parallel as an example # Your parallel code stopCluster(cl) Когда я запустил это…
10 сен '18 в 19:42
0 ответов

R Google Compute Engine создает ошибку кластера

Я пытаюсь создать кластер R на виртуальных машинах на GCE. Я последовал примеру googleComputeEngineR. Я вставил код ниже. ###### vm_names <- paste0("cpu",1:2) ## specify the cheapest VMs that may get turned off preemptible = list(preemptible = TR…
10 окт '18 в 18:43
1 ответ

Является ли функция типа `purrr::map()` внутри `future.apply::future_apply()` также запущенной параллельно?

Извините, если это глупые вопросы, но я почти ничего не знаю о том, как параллельная обработка работает на практике. Мои вопросы:- Q1. Это функция как purrr::map() в future.apply::future_apply() также работает параллельно?- Q2. Что произойдет, если …
16 фев '19 в 10:56
1 ответ

Есть ли способ вручную прикрепить пакеты и глобальные переменные с помощью `future.apply::future_apply`

Я использую превосходный будущий пакет R. И в документации это упоминает %global% а также %packages% для назначения глобальных переменных и пакетов для оценки в будущей среде. Но те, кажется, работают только с %<-%, Мой вопрос: есть ли это сделат…
13 фев '19 в 12:34
0 ответов

R будущее, doSNOW, параллельное и foreach для асинхронного выполнения

Я борюсь с выбором подходящего пакета для параллельного асинхронного выполнения скриптов внешними программами с R (R скрипт также предоставляет входные данные и агрегирует выходные данные), я знаю о четырех популярных пакетах: future, doSNOW, паралл…
23 янв '19 в 14:26
1 ответ

Каков идиоматичный, гибкий способ определения плана многопроцессорности в будущем?

Я только что столкнулся с R пакетами и будущими. Я хотел бы использовать их для написания гибкого кода, который будет использовать несколько ядер, если они доступны на машинах под управлением Windows или OSX. Я хотел бы, чтобы по умолчанию число "до…
23 янв '19 в 21:32
0 ответов

furrr не находит свою посылку

В настоящее время я работаю над пакетом, скажем, он называется myPack. У меня есть функция с именем myFunc1 и другая функция с именем myFunc2, которая выглядит примерно так: myFunc2 <- function(x, parallel = FALSE) { if(parallel) future::plan(fut…
03 мар '19 в 12:41
1 ответ

R будущее многосессионное ограничение числа процессоров

В настоящее время я распараллеливаюсь, используя следующий пакет: plan(multisession, gc = TRUE) standardised_addresses1 <- future_lapply(1:20000, function(x) x*x) Проблема в том, что он использует все процессоры на сервере. Я хотел бы ограничить …
15 авг '19 в 03:10
1 ответ

Асинхронное программирование в R

обзор Я пишу программу (на R), которая выполняет вызовы API в определенное время. Вызовы API занимают некоторое время, но мне нужно, чтобы таймер (основной цикл) продолжал считать, пока выполняется вызов API. Для этого мне нужно "передать" вызов API…
29 июн '19 в 03:21