fix: only check local workers when processes are available

mlr-org · Aug 22, 2024 · 2281f08 · 2281f08
1 parent 25061b6
commit 2281f08
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/R/Rush.R b/R/Rush.R
@@ -473,7 +473,7 @@ Rush = R6::R6Class("Rush",
 
       # check local workers without a heartbeat
       local_workers = r$SMEMBERS(private$.get_key("local_workers"))
-      lost_workers_local = if (length(local_workers)) {
+      lost_workers_local = if (length(local_workers) && !is.null(self$processes)) {
         # lg$debug("Checking %i worker(s) with process id", length(local_workers))
         running = map_lgl(local_workers, function(worker_id) self$processes[[worker_id]]$is_alive())
         if (all(running)) return(invisible(self))