test: expect_rush_reset changes related to rush developments

Author: sumny

tests/testthat/helper.R

@@ -220,9 +220,17 @@ expect_acqfunction = function(acqf) {
 }
 
 expect_rush_reset = function(rush, type = "kill") {
-  processes = rush$processes
+  processes = if (exists("processes", rush)) {
+    rush$processes
+  } else {
+    rush$processes_processx %??% rush$processes_mirai
+  }
   rush$reset(type = type)
-  expect_list(rush$connector$command(c("KEYS", "*")), len = 0)
+  Sys.sleep(1L)
+  keys = rush$connector$command(c("KEYS", "*"))
+  if (!test_list(keys, len = 0)) {
+    stopf("Found keys in redis after reset: %s", keys)
+  }
   walk(processes, function(p) p$kill())
 }
 

tests/testthat/test_OptimizerAsyncMbo.R

@@ -38,8 +38,8 @@ test_that("OptimizerAsyncMbo works with evaluations in archive", {
   instance$terminator$param_set$values$n_evals = 40L
 
   optimizer = opt("async_mbo")
+  optimizer$optimize(instance)
 
-  expect_data_table(optimizer$optimize(instance), nrows = 1L)
   expect_data_table(instance$archive$data[is.na(get("acq_cb"))], min.rows = 10L)
   expect_data_table(instance$archive$data[!is.na(get("acq_cb"))], min.rows = 20L)