Need to tryCatch() worker cleanup

gaborcsardi · gaborcsardi · commit a5b90c1536fd · 2025-10-11T11:06:25.000+02:00
In case the process has terminated already.
diff --git a/R/parallel.R b/R/parallel.R
@@ -361,9 +361,9 @@ queue_teardown <- function(queue) {
         error = function(e) NULL
       )
       if (ps::ps_is_supported()) {
-        tasks$worker[[i]]$kill_tree()
+        tryCatch(tasks$worker[[i]]$kill_tree(), error = function(e) NULL)
       } else {
-        tasks$worker[[i]]$kill()
+        tryCatch(tasks$worker[[i]]$kill(), error = function(e) NULL)
       }
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -361,9 +361,9 @@ queue_teardown <- function(queue) {`
`361`	`361`	`error = function(e) NULL`
`362`	`362`	`)`
`363`	`363`	`if (ps::ps_is_supported()) {`
`364`		`- tasks$worker[[i]]$kill_tree()`
	`364`	`+ tryCatch(tasks$worker[[i]]$kill_tree(), error = function(e) NULL)`
`365`	`365`	`} else {`
`366`		`- tasks$worker[[i]]$kill()`
	`366`	`+ tryCatch(tasks$worker[[i]]$kill(), error = function(e) NULL)`
`367`	`367`	`}`
`368`	`368`	`}`
`369`	`369`	`}`