R/resources_OP.R

In future.BatchJobs: A Future API for Parallel and Distributed Processing using BatchJobs

#' Temporarily tweaks the resources for the current BatchJobs strategy
#'
#' @usage fassignment \%resources\% tweaks
#'
#' @param fassignment The future assignment, e.g.
#'        \code{x \%<-\% \{ expr \}}.
#' @param tweaks A named list (or vector) of resource
#' BatchJobs parameters that should be changed relative to
#' the current strategy.
#'
#' @export
#' @importFrom future plan tweak
#' @keywords internal
`%resources%` <- function(fassignment, tweaks) {
  fassignment <- substitute(fassignment)
  envir <- parent.frame(1)
  stop_if_not(is.vector(tweaks))
  tweaks <- as.list(tweaks)
  stop_if_not(!is.null(names(tweaks)))

  ## Temporarily use a different plan
  oplan <- plan("list")
  on.exit(plan(oplan, substitute=FALSE, .call=NULL))

  ## Tweak current strategy and apply
  args <- list(plan("next"), resources=tweaks, penvir=envir)
  strategy <- do.call(tweak, args=args)
  plan(strategy, substitute=FALSE, .call=NULL)

  eval(fassignment, envir=envir, enclos = baseenv())
}