Allow parameterization of R future strategy

Author: bbimber

singlecell/resources/chunks/Functions.R

@@ -173,17 +173,21 @@ readSeuratRDS <- function(filePath) {
     return(seuratObj)
 }
 
-print('Updating future.globals.maxSize')
-options(future.globals.maxSize = Inf)
-
-options('Seurat.memsafe' = TRUE, future.globals.onReference = "warning")
+options(future.globals.maxSize = Inf, future.globals.onReference = "warning")
+options('Seurat.memsafe' = TRUE)
 
 if (Sys.getenv('SEURAT_MAX_THREADS') != '') {
-    print(paste0('Setting future::plan workers to: ', Sys.getenv('SEURAT_MAX_THREADS')))
+    logger::log_info(paste0('Setting future::plan workers to: ', Sys.getenv('SEURAT_MAX_THREADS')))
     mt <- as.integer(Sys.getenv('SEURAT_MAX_THREADS'))
     if (is.na(mt)) {
         stop(paste0('SEURAT_MAX_THREAD is not an integer: ', mt <- Sys.getenv('SEURAT_MAX_THREADS')))
     }
 
-    future::plan(strategy='multisession', workers=mt)
+    fs <- ifelse(exists('futureStrategy'), yes = get('futureStrategy'), no = 'multicore')
+    if (mt == 1) {
+        fs <- 'sequential'
+    }
+    logger::log_info(paste0('Setting future::strategy to: ', fs))
+
+    future::plan(strategy = fs, workers = mt)
 }