R/class_resources_crew.R

In targets: Dynamic Function-Oriented 'Make'-Like Declarative Pipelines

resources_crew_init <- function(
  controller = NULL,
  seconds_timeout = NULL
) {
  resources_crew_new(
    controller = controller,
    seconds_timeout = seconds_timeout
  )
}

resources_crew_new <- function(
  controller = NULL,
  seconds_timeout = NULL
) {
  out <- new.env(parent = emptyenv(), hash = FALSE)
  out$controller <- controller
  out$seconds_timeout <- seconds_timeout
  enclass(out, resources_crew_s3_class)
}

resources_crew_s3_class <- c("tar_resources_crew", "tar_resources")

#' @export
resources_validate.tar_resources_crew <- function(resources) {
  if (!is.null(resources$controller)) {
    tar_assert_chr(resources$controller)
    tar_assert_scalar(resources$controller)
    tar_assert_none_na(resources$controller)
    tar_assert_nzchar(resources$controller)
  }
  if (!is.null(resources$seconds_timeout)) {
    tar_assert_dbl(resources$seconds_timeout)
    tar_assert_scalar(resources$seconds_timeout)
    tar_assert_none_na(resources$seconds_timeout)
    tar_assert_positive(resources$seconds_timeout)
  }
}

#' @export
print.tar_resources_crew <- function(x, ...) {
  cat(
    "<tar_resources_crew>\n ",
    paste0(paste_list(as.list(x)), collapse = "\n  ")
  )
}