diff --git a/R/clusterFunctionsMulticore.R b/R/clusterFunctionsMulticore.R index 6c2b84b9..1c36aae6 100644 --- a/R/clusterFunctionsMulticore.R +++ b/R/clusterFunctionsMulticore.R @@ -32,7 +32,7 @@ Multicore = R6Class("Multicore", initialize = function(ncpus) { self$jobs = data.table(pid = integer(0L), count = integer(0L)) self$ncpus = ncpus - reg.finalizer(self, function(e) mccollect(self$procs$pid, timeout = 1), onexit = FALSE) + reg.finalizer(self, function(e) mccollect(self$jobs$pid, timeout = 1), onexit = FALSE) }, spawn = function(jc) {