testing

wlandau · Sep 9, 2024 · efb1f9b · efb1f9b
1 parent f433a66
commit efb1f9b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/tests/local/test-cleanup.R b/tests/local/test-cleanup.R
@@ -1,14 +1,12 @@
 crew_test("workers signal themselves to exit when connection breaks", {
-  skip_if_not_installed("mirai", minimum_version = "0.11.3.9000")
-  skip_if_not_installed("nanonext", minimum_version = "0.11.0.9000")
   x <- crew_controller_local(workers = 1L)
   x$start()
   x$push(nanonext::until(nanonext::cv(), 600 * 1e3))
   Sys.sleep(2)
   x$scale()
   Sys.sleep(2)
-  dispatcher <- ps::ps_handle(pid = x$client$dispatcher)
-  crew_terminate_process(x$client$dispatcher)
+  dispatcher <- x$client$dispatcher
+  crew_terminate_process(ps::ps_pid(dispatcher))
   crew_retry(
     ~!ps::ps_is_running(dispatcher),
     seconds_interval = 0.5,

diff --git a/tests/local/test-crew_clean.R b/tests/local/test-crew_clean.R
@@ -11,7 +11,7 @@ crew_test("crew_clean()", {
     crew_test_sleep()
   })
   x$start()
-  handle_dispatcher <- ps::ps_handle(x$client$dispatcher)
+  handle_dispatcher <- x$client$dispatcher
   expect_true(ps::ps_is_running(handle_dispatcher))
   x$launch(n = 1L)
   handle_worker <- x$launcher$workers$handle[[1]]