From 9e95deb2251fbdb51be66146763798d37e396e8e Mon Sep 17 00:00:00 2001 From: pat-s Date: Sat, 27 Jul 2024 13:46:23 +0200 Subject: [PATCH] 6 workers --- .woodpecker/build.yaml | 8 ++++---- R/build_binaries.R | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/.woodpecker/build.yaml b/.woodpecker/build.yaml index 9e694d9..72c563b 100644 --- a/.woodpecker/build.yaml +++ b/.woodpecker/build.yaml @@ -38,16 +38,16 @@ steps: # Hmisc -> ABCanalysis - R -q -e 'pak::pak(c("Hmisc", "pls", "abd", "doRNG"))' - mkdir -p /mnt/cache/pkgcache /mnt/cache/R-pkgs /mnt/cache/binaries - - R -q -e 'options(crayon.enabled = TRUE, Ncpus = 4, future.globals.onReference = "error"); pkgs = tools::CRAN_package_db()[[1]][16:20]; library(rBinaries); future::plan("multisession", workers = 4, rscript_startup = quote(options(crayon.enabled = TRUE))); foo = lapply(pkgs, function(x) build_binary_package(x, build_for_minor=FALSE, debug = FALSE, force = TRUE))' + - R -q -e 'options(crayon.enabled = TRUE, Ncpus = 6, future.globals.onReference = "error"); pkgs = tools::CRAN_package_db()[[1]][16:20]; library(rBinaries); future::plan("multisession", workers = 6, rscript_startup = quote(options(crayon.enabled = TRUE))); foo = lapply(pkgs, function(x) build_binary_package(x, build_for_minor=FALSE, debug = FALSE, force = TRUE))' backend_options: kubernetes: resources: requests: - memory: 2000Mi + memory: 3000Mi cpu: 2000m limits: - memory: 6000Mi - cpu: 4050m + memory: 4000Mi + cpu: 6050m nodeSelector: kubernetes.io/arch: 'arm64' # - name: Sleep diff --git a/R/build_binaries.R b/R/build_binaries.R index 0dd6fbc..c179924 100644 --- a/R/build_binaries.R +++ b/R/build_binaries.R @@ -77,7 +77,7 @@ build_binary_package <- function(package_name, tag = NULL, codename = NULL, out <- progressr::with_progress({ p <- progressr::progressor(along = tag) - future::future_mapply(function(x, y) { + future.apply::future_mapply(function(x, y) { tryCatch( { p() @@ -107,7 +107,7 @@ build_binary_package <- function(package_name, tag = NULL, codename = NULL, cli::cli_h2("Uploading ({.pkg {package_name[1]}})") out <- progressr::with_progress({ p <- progressr::progressor(along = tag) - future::future_mapply(function(x, y) { + future.apply::future_mapply(function(x, y) { tryCatch( { p()