tests/testthat/test-utils_mirai.R

In wlandau/crew: A Distributed Worker Launcher Framework

crew_test("mirai_status()", {
  skip_on_cran()
  skip_on_os("windows")
  out <- mirai_status(
    profile = "none",
    seconds_interval = 1L,
    seconds_timeout = 15L
  )
  expect_true(is.list(out))
})

crew_test("mirai_status_error()", {
  skip_on_cran()
  expect_crew_error(mirai_status_error(status = 5L, profile = "default"))
})

crew_test("mirai_resolved()", {
  skip_on_cran()
  skip_on_os("windows")
  expect_true(mirai_resolved(TRUE))
  task <- mirai::mirai(TRUE)
  mirai::call_mirai_(task)
  expect_true(mirai_resolved(task))
  ask <- mirai::mirai(stop("abc"))
  mirai::call_mirai_(task)
  expect_true(mirai_resolved(task))
  task <- mirai::mirai(Sys.sleep(1))
  expect_false(mirai_resolved(task))
  mirai::call_mirai_(task)
})

crew_test("mirai_resolve()", {
  skip_on_cran()
  skip_on_os("windows")
  expect_equal(mirai_resolve(list("abc"), launching = TRUE), list("abc"))
  expect_equal(
    mirai_resolve(mirai::mirai(list(a = 1L, b = 2L)), launching = TRUE),
    list(a = 1L, b = 2L)
  )
  expect_crew_error(
    mirai_resolve(
      task = mirai::mirai({
        Sys.sleep(0.5)
        stop("abc")
      }),
      launching = TRUE
    )
  )
})

crew_test("mirai_wait()", {
  skip_on_cran()
  skip_on_os("windows")
  tasks <- replicate(2L, mirai::mirai(TRUE), simplify = FALSE)
  expect_silent(mirai_wait(tasks, launching = TRUE))
  expect_crew_error(
    mirai_wait(
      tasks = list(
        mirai::mirai(TRUE),
        mirai::mirai({
          Sys.sleep(1)
          stop("abc")
        })
      ),
      launching = TRUE
    )
  )
})

crew_test("mirai_assert()", {
  skip_on_cran()
  skip_on_os("windows")
  expect_silent(mirai_assert(task = "task", launching = TRUE))
  task <- mirai::mirai(TRUE)
  mirai::call_mirai_(task)
  expect_silent(mirai_assert(task, launching = TRUE))
  task <- mirai::mirai(stop("message"))
  mirai::call_mirai_(task)
  expect_crew_error(mirai_assert(task, launching = TRUE))
  expect_warning(
    mirai_assert(task, launching = FALSE),
    class = "crew_warning"
  )
})