tests/testthat/test-tasks.R

In mrc-ide/queuer: Queue Tasks

context("queuer_tasks")

test_that("basic", {
  path <- tempfile("queuer_")
  on.exit(unlink(path, recursive = TRUE))

  ctx <- context::context_load(context::context_save(path),
                               new.env(parent = .GlobalEnv))
  id <- context::task_save(quote(sin(1)), ctx)

  t <- queuer_task$new(id, ctx)

  expect_is(t, "queuer_task")
  expect_equal(t$status(), "PENDING")
  expect_equal(t$expr(), quote(sin(1)))
  expect_equal(t$context_id(), ctx$id)
  expect_error(t$result(), "is unfetchable", class = "UnfetchableTask")
  expect_is(t$result(TRUE), "UnfetchableTask")

  ## expect_error(t$log(), "No log for")
  expect_error(t$wait(0), "task not returned in time")
  expect_error(t$wait(0.01), "task not returned in time")
  expect_true(system.time(try(t$wait(0.01), silent = TRUE))[["elapsed"]] < 0.5)

  tt <- t$times()
  expect_is(tt, "data.frame")
  expect_is(tt$submitted, "POSIXt")
  expect_equal(tt$started, as.POSIXct(NA))
  expect_equal(tt$finished, as.POSIXct(NA))

  ## file <- path_log(t$root, t$id)
  file <- NULL
  res <- context::task_run(t$id, ctx, filename = file)
  ## readLines(file)
  ## t$log()

  expect_equal(t$status(), "COMPLETE")
  expect_equal(t$result(), sin(1))
  expect_equal(t$wait(0), sin(1))
  expect_equal(t$wait(0.1), sin(1))

  ## t$times()
  ## tasks_list(t)
})

test_that("missing task", {
  path <- tempfile("queuer_")
  on.exit(unlink(path, recursive = TRUE))
  ctx <- context::context_save(path)
  expect_error(queuer_task$new(ids::random_id(), ctx),
               "Task does not exist")

  t <- queuer_task$new(ids::random_id(), ctx, FALSE)
  expect_equal(t$context_id(), NA_character_)
  expect_error(t$expr(), "not found", class = "KeyError")
  expect_equal(t$status(), "MISSING")
  expect_error(t$result(), "unfetchable: MISSING", class = "UnfetchableTask")
  expect_is(t$result(TRUE), "UnfetchableTask")
})

test_that("Expressions namespace-qualified arguments are allowed", {
  path <- tempfile("queuer_")
  on.exit(unlink(path, recursive = TRUE))
  ctx <- context::context_save(path, storage_type = "environment")
  obj <- queue_base$new(ctx)
  ## This replicates issue #13
  x <- 1
  t <- obj$enqueue(foo(x, ids::random_id))
  expect_equal(t$expr(), quote(foo(x, ids::random_id)))
})