Utility functions for relaying stdout and conditions when using mclapply()/parLapply(), ...
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 5/5
- Tempo stimato
- Più di una settimana
- Idoneità per principianti
- 25/100
- Tipo di issue
- Funzionalità
- Chiarezza
- Da chiarire
- Stato di attività
- Ferma
- Stack tecnologico
- r
- Ambito
- distributed-systems
Direzione di ricerca
Inizia con gli esempi di mclapply() e parLapply() nell’issue, quindi leggi il comportamento del pacchetto parallel per i worker del cluster e confrontalo con il modello progressr/futures menzionato. Il lavoro sarebbe completo quando fosse definita un’API per inoltrare stdout, conditions e aggiornamenti sul progresso, e fosse documentato il comportamento per recuperare i valori risultanti.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
I'm adding this one to this package, but it probably belongs to a 'parallel.extras' package:
Add some type of utility functions for relaying stdout and conditions when using mclapply(), parLapply(), ... of the 'parallel' package. Not sure what such an API would look like, but it might help us support 'progressr' also in those cases, because current the following will relay nothing from the cluster nodes:
library(progressr)
options(progressr.interval = 0.0, progressr.delay = 0.01)
cl <- parallel::makeCluster(3)
with_progress({
p <- progressor(10)
parallel::clusterExport(cl, c("p", "slow_sum"))
y <- parallel::parLapply(cl, X = 1:10, function(x) {
p()
slow_sum(x, stdout=TRUE, message=TRUE)
})
})
parallel::stopCluster(cl)
Maybe something that will allow us to do:
res <- parallel::parLapply(cl, X = 1:10, function(x) record_output({
p()
slow_sum(x, stdout=TRUE, message=TRUE)
}))
y <- value(res) ## cf. how futures work
- Lingua principale
- R
- Stelle
- 299
- Fork
- 11
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Preparare l'ambiente
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di futureverse/progressr
-
Difficoltà 3/5 1-2 giorni Idoneità per principianti 63/100
futureverse/progressr#198 · 1 commento ·
-
Difficoltà 4/5 3-5 giorni Idoneità per principianti 45/100
futureverse/progressr#197 ·
-
Difficoltà 3/5 1-2 giorni Idoneità per principianti 55/100
futureverse/progressr#195 ·
-
Difficoltà 4/5 3-5 giorni Idoneità per principianti 28/100
futureverse/progressr#191 ·
-
question
Difficoltà 3/5 1-2 giorni Idoneità per principianti 35/100
futureverse/progressr#155 · 5 commenti ·
Tutte le issue di futureverse/progressr
Issue simili
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 72/100
datacarpentry/semester-biology#1266 ·
I maintainer di solito rispondono entro 1 giorno
-
enhancement
Difficoltà 2/5 1-3 ore Idoneità per principianti 72/100
REditorSupport/vscode-R#1785 · 1 commento ·
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 90/100
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 75/100
ImperialCollegeLondon/ve_data_science#666 ·
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 92/100
I maintainer di solito rispondono entro 13 giorni