Fix #265

ropensci · Jan 12, 2021 · e6e645f · e6e645f
1 parent 0aeabe8
commit e6e645f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/R/class_clustermq.R b/R/class_clustermq.R
@@ -185,12 +185,12 @@ clustermq_class <- R6::R6Class(
       )
     },
     run_clustermq = function() {
-      on.exit(self$crew$finalize())
+      on.exit(try(self$crew$finalize()))
       self$start_crew(self$pipeline$envir)
       while (self$scheduler$progress$any_remaining()) {
         self$iterate()
       }
-      if (self$crew$cleanup()) {
+      if (identical(try(self$crew$cleanup()), TRUE)) {
         on.exit()
       }
     },