retries in a test

wlandau · May 17, 2024 · b8e9fcc · b8e9fcc
1 parent 8e135c2
commit b8e9fcc
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/tests/testthat/test-plugins.R b/tests/testthat/test-plugins.R
@@ -327,10 +327,18 @@ crew_test("custom launcher with async internal launcher tasks", {
   })
   controller$push(name = "pid", command = ps::ps_pid())
   controller$wait(seconds_timeout = 10, seconds_interval = 0.5)
-  out <- controller$pop()$result[[1L]]
+  envir <- new.env(parent = emptyenv())
+  crew_retry(
+    ~ {
+      envir$pid <- controller$pop()$result[[1L]]
+      !is.null(envir$pid)
+    },
+    seconds_interval = 0.25,
+    seconds_timeout = 15
+  )
   handle <- controller$launcher$workers$handle[[1L]]
   pid <- handle$data$pid
-  expect_equal(out, pid)
+  expect_equal(envir$pid, pid)
   expect_equal(handle$data$status, "started")
   controller$launcher$terminate()
   handle <- controller$launcher$workers$termination[[1L]]