tests/testthat/test_run_task.R

In shinybatch: Launch Tasks in Batch

context("test_run_task")

# create temporary directory for conf
dir_conf <- paste0(tempdir(), "/conf")
if (dir.exists(dir_conf)) unlink(dir_conf, recursive = TRUE)
dir.create(dir_conf, recursive = T)

# ex fun 
fun_path = system.file("ex_fun/sb_fun_ex.R", package = "shinybatch")
fun_name = "sb_fun_ex"

# create and save conf
conf <- configure_task(dir_path = dir_conf,
                       conf_descr = list(title = "my_title",
                                         description = "my_descr"),
                       fun_path = fun_path,
                       fun_name = fun_name,
                       fun_args = list(x = 1,
                                       y = 0:4,
                                       z = iris),
                       priority = 1)


test_that("test outputs", {
  
  # fun output
  expect_equal(suppressWarnings(run_task(paste0(conf$dir, "conf.yml"))), 1:5)
  
  # conf updates
  #####
  # 1 #
  #####
  expect_equal(yaml::read_yaml(paste0(conf$dir, "conf.yml"))$run_info$status, "finished")

  #####
  # 2 #
  #####
  # create temporary directory for conf
  dir_conf <- tempdir()
  # create temporary directory for fun
  dir_fun <- paste0(tempdir(), "/fun")
  if (dir.exists(dir_fun)) unlink(dir_fun, recursive = TRUE)
  dir.create(dir_fun)
  con <- file(paste0(dir_fun, "/fun_script.R"))
  writeLines(c("my_fun <- function(x, y, z) {",
               "  res <- x + y ;",
               "  stop('Error') ;",
               "  res",
               "}"),
             con)
  close(con)
  
  # create and save conf
  conf <- configure_task(dir_path = dir_conf,
                         conf_descr = list(title = "my_title",
                                           description = "my_descr"),
                         fun_path = paste0(dir_fun, "/fun_script.R"),
                         fun_name = "my_fun",
                         fun_args = list(x = 1,
                                         y = 0:4,
                                         z = iris),
                         priority = 1)
  
  time <- Sys.time()
  try(run_task(paste0(conf$dir, "conf.yml")), silent = T)
  
  expect_equal(yaml::read_yaml(paste0(conf$dir, "conf.yml"))$run_info$status, "error")
  
})