6 workers

This commit is contained in:
Patrick Schratz 2024-07-27 13:46:23 +02:00
commit 9e95deb225
Signed by: pat-s
GPG key ID: 3C6318841EF78925
2 changed files with 6 additions and 6 deletions

View file

@ -38,16 +38,16 @@ steps:
# Hmisc -> ABCanalysis # Hmisc -> ABCanalysis
- R -q -e 'pak::pak(c("Hmisc", "pls", "abd", "doRNG"))' - R -q -e 'pak::pak(c("Hmisc", "pls", "abd", "doRNG"))'
- mkdir -p /mnt/cache/pkgcache /mnt/cache/R-pkgs /mnt/cache/binaries - 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: backend_options:
kubernetes: kubernetes:
resources: resources:
requests: requests:
memory: 2000Mi memory: 3000Mi
cpu: 2000m cpu: 2000m
limits: limits:
memory: 6000Mi memory: 4000Mi
cpu: 4050m cpu: 6050m
nodeSelector: nodeSelector:
kubernetes.io/arch: 'arm64' kubernetes.io/arch: 'arm64'
# - name: Sleep # - name: Sleep

View file

@ -77,7 +77,7 @@ build_binary_package <- function(package_name, tag = NULL, codename = NULL,
out <- progressr::with_progress({ out <- progressr::with_progress({
p <- progressr::progressor(along = tag) p <- progressr::progressor(along = tag)
future::future_mapply(function(x, y) { future.apply::future_mapply(function(x, y) {
tryCatch( tryCatch(
{ {
p() p()
@ -107,7 +107,7 @@ build_binary_package <- function(package_name, tag = NULL, codename = NULL,
cli::cli_h2("Uploading ({.pkg {package_name[1]}})") cli::cli_h2("Uploading ({.pkg {package_name[1]}})")
out <- progressr::with_progress({ out <- progressr::with_progress({
p <- progressr::progressor(along = tag) p <- progressr::progressor(along = tag)
future::future_mapply(function(x, y) { future.apply::future_mapply(function(x, y) {
tryCatch( tryCatch(
{ {
p() p()