Marshal pipeline at the right time

ropensci · Apr 14, 2024 · 83c00c4 · 83c00c4
1 parent 9979bf4
commit 83c00c4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/R/class_clustermq.R b/R/class_clustermq.R
@@ -129,6 +129,7 @@ clustermq_class <- R6::R6Class(
       length(need_workers) > 0L
     },
     run_worker = function(target) {
+      builder_marshal_subpipeline(target)
       if (self$garbage_collection) {
         gc()
       }
@@ -161,7 +162,6 @@ clustermq_class <- R6::R6Class(
     run_target = function(name) {
       target <- pipeline_get_target(self$pipeline, name)
       target_prepare(target, self$pipeline, self$scheduler, self$meta)
-      builder_marshal_subpipeline(target)
       self$sync_meta_time()
       if_any(
         target_should_run_worker(target),

diff --git a/R/class_future.R b/R/class_future.R
@@ -97,6 +97,7 @@ future_class <- R6::R6Class(
       self$worker_list <- memory_init()
     },
     run_worker = function(target) {
+      builder_marshal_subpipeline(target)
       if (self$garbage_collection) {
         gc()
       }
@@ -162,7 +163,6 @@ future_class <- R6::R6Class(
     run_target = function(name) {
       target <- pipeline_get_target(self$pipeline, name)
       target_prepare(target, self$pipeline, self$scheduler, self$meta)
-      builder_marshal_subpipeline(target)
       self$sync_meta_time()
       if_any(
         target_should_run_worker(target),