tests/testthat/core/test-cluster.R

In Azure/doAzureParallel: doAzureParallel

context("Cluster Management Test")

test_that("Create Cluster Test", {
  testthat::skip_on_travis()
  source("utility.R")

  settings <- getSettings()
  cluster <-
    doAzureParallel::makeCluster(settings$clusterConfig, wait = FALSE)

  cluster <- getCluster(cluster$poolId)
  clusterList <- getClusterList()
  filter <- list()
  filter$state <- c("active", "deleting")

  testthat::expect_true('test-pool' %in% clusterList$Id)
})

test_that("Get Cluster Test", {
  testthat::skip_on_travis()
  source("utility.R")

  settings <- getSettings()

  cluster <-
    doAzureParallel::makeCluster(settings$clusterConfig, wait = FALSE)

  cluster <- getCluster(cluster$poolId)
  clusterList <- getClusterList()
  filter <- list()
  filter$state <- c("active", "deleting")

  testthat::expect_true('test-pool' %in% clusterList$Id)

  clusterList <- getClusterList(filter)

  for (i in 1:length(clusterList$State)) {
    testthat::expect_true(clusterList$State[i] == 'active' ||
                          clusterList$State[i] == 'deleting')
  }
})

test_that("Autoscale Cluster Test", {
  testthat::skip_on_travis()
  source("utility.R")

  settings <- getSettings()

  cluster <-
    doAzureParallel::makeCluster(settings$clusterConfig, wait = FALSE)

  cluster <- getCluster(cluster$poolId)
  clusterList <- getClusterList()
  filter <- list()
  filter$state <- c("active", "deleting")

  testthat::expect_true('test-pool' %in% clusterList$Id)

  clusterList <- getClusterList(filter)

  for (i in 1:length(clusterList$State)) {
    testthat::expect_true(clusterList$State[i] == 'active' ||
                            clusterList$State[i] == 'deleting')
  }
})

test_that("Delete Cluster Test", {
  testthat::skip_on_travis()
  source("utility.R")

  settings <- getSettings()

  cluster <-
    doAzureParallel::makeCluster(settings$clusterConfig, wait = FALSE)

  doAzureParallel::stopCluster(cluster)

  testthat::expect_true('test-pool' %in% clusterList$Id)

  clusterList <- getClusterList(filter)
})