Add progress reporting for all parallel operations

tidyverts · Aug 29, 2024 · 973dab7 · 973dab7
1 parent 6865b67
commit 973dab7
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/R/utils.R b/R/utils.R
@@ -256,11 +256,15 @@ flatten_with_names <- function (x, sep = "_") {
 }
 
 mapply_maybe_parallel <- function (.f, ..., MoreArgs = list(), SIMPLIFY = FALSE) {
+  p <- progressr::progressor(length(..1))
+  .fp <- function(...) {
+    p()
+    .f(...)
+  }
   if(is_attached("package:future")){
     require_package("future.apply")
-
     future.apply::future_mapply(
-      FUN = .f,
+      FUN = .fp,
       ...,
       MoreArgs = MoreArgs,
       SIMPLIFY = SIMPLIFY,
@@ -270,7 +274,7 @@ mapply_maybe_parallel <- function (.f, ..., MoreArgs = list(), SIMPLIFY = FALSE)
   }
   else{
     mapply(
-      FUN = .f,
+      FUN = .fp,
       ...,
       MoreArgs = MoreArgs,
       SIMPLIFY = SIMPLIFY