BatchtoolsFutureBackend gained explicit argument 'interrupts = TRUE'

Author: HenrikBengtsson

DESCRIPTION

@@ -1,5 +1,5 @@
 Package: future.batchtools
-Version: 0.12.2-9909
+Version: 0.12.2-9910
 Depends:
     R (>= 3.2.0),
     parallelly,

NEWS.md

@@ -9,8 +9,11 @@
 
  * Most types of batchtools future can now be interrupted, including
    `batchtools_multicore` and all job-scheduler backends, e.g.
-   `batchtools_sge` and `batchtools_slurm`. 
- 
+   `batchtools_sge` and `batchtools_slurm`.
+
+ * Canceling of batchtools future will now interrupt them by default,
+   for backends where it is supported.
+
 
 # Version 0.12.2 [2025-06-06]
 

R/BatchtoolsFuture-class.R

@@ -1,5 +1,7 @@
 #' A batchtools future is a future whose value will be resolved via batchtools
 #'
+#' @inheritParams future::FutureBackend
+#'
 #' @param resources (optional) A named list passed to the \pkg{batchtools}
 #' template (available as variable `resources`).  See Section 'Resources'
 #' in [batchtools::submitJobs()] more details.
@@ -39,6 +41,7 @@ BatchtoolsFutureBackend <- function(workers = NULL, resources = list(),
                              conf.file = findConfFile(),
                              cluster.functions = NULL,
                              registry = list(),
+                             interrupts = TRUE,
                              ...) {
   assert_no_positional_args_but_first()
 
@@ -79,7 +82,7 @@ BatchtoolsFutureBackend <- function(workers = NULL, resources = list(),
   }
 
   stop_if_not(is.list(resources))
-
+  
   core <- FutureBackend(
     reg = "workers-batchtools",
     workers = workers,
@@ -88,6 +91,7 @@ BatchtoolsFutureBackend <- function(workers = NULL, resources = list(),
     cluster.functions = cluster.functions,
     registry = registry,
     finalize = finalize,
+    interrupts = interrupts,
     future.wait.timeout = getOption("future.wait.timeout", 30 * 24 * 60 * 60),
     future.wait.interval = getOption("future.wait.interval", 0.01),
     future.wait.alpha = getOption("future.wait.alpha", 1.01),
@@ -343,7 +347,12 @@ interruptFuture.BatchtoolsFutureBackend <- function(backend, future, ...) {
       mdebug_pop()
     })
   }
-    
+
+  if (!backend[["interrupts"]]) {
+    if (debug) mdebug("Interrupts are disabled for the current backend")
+    return(future)
+  }
+  
   config <- future[["config"]]
   reg <- config[["reg"]]