Release v1.1.2

DESCRIPTION

@@ -1,8 +1,8 @@
 Package: Strategus
 Type: Package
 Title: Coordinate and Execute OHDSI HADES Modules
-Version: 1.1.1
-Date: 2024-12-03
+Version: 1.1.2
+Date: 2024-12-04
 Authors@R: c(
 	person("Anthony", "Sena", email = "[email protected]", role = c("aut", "cre")),
 	person("Martijn", "Schuemie", email = "[email protected]", role = c("aut")),

NEWS.md

@@ -1,3 +1,7 @@
+Strategus 1.1.2
+===============
+- Add options for overriding number of threads for database operations (#190)
+
 Strategus 1.1.1
 ===============
 - Fixes R CMD note and updates documentation for inclusion into HADES

R/Module-CohortMethod.R

@@ -23,6 +23,14 @@ CohortMethodModule <- R6::R6Class(
       jobContext <- private$jobContext
       multiThreadingSettings <- CohortMethod::createDefaultMultiThreadingSettings(jobContext$moduleExecutionSettings$maxCores)
 
+      # Provide hook to allow for overriding the number of threads
+      # used for database operations
+      getDbCohortMethodDataThreads <- as.integer(getOption("strategus.CohortMethodModule.getDbCohortMethodDataThreads"))
+      if (isTRUE(getDbCohortMethodDataThreads > 0)) {
+        private$.message(paste0("Detected strategus.CohortMethodModule.getDbCohortMethodDataThreads - setting value to: ", getDbCohortMethodDataThreads))
+        multiThreadingSettings$getDbCohortMethodDataThreads <- getDbCohortMethodDataThreads
+      }
+
       args <- jobContext$settings
       args$connectionDetails <- connectionDetails
       args$cdmDatabaseSchema <- jobContext$moduleExecutionSettings$cdmDatabaseSchema

R/Module-SelfControlledCaseSeries.R

@@ -25,6 +25,14 @@ SelfControlledCaseSeriesModule <- R6::R6Class(
       jobContext <- private$jobContext
       sccsMultiThreadingSettings <- SelfControlledCaseSeries::createDefaultSccsMultiThreadingSettings(jobContext$moduleExecutionSettings$maxCores)
 
+      # Provide hook to allow for overriding the number of threads
+      # used for database operations
+      getDbSccsDataThreads <- as.integer(getOption("strategus.SelfControlledCaseSeriesModule.getDbSccsDataThreads"))
+      if (isTRUE(getDbSccsDataThreads > 0)) {
+        private$.message(paste0("Detected strategus.SelfControlledCaseSeriesModule.getDbSccsDataThreads - setting value to: ", getDbSccsDataThreads))
+        sccsMultiThreadingSettings$getDbSccsDataThreads <- getDbSccsDataThreads
+      }
+
       args <- jobContext$settings
       args$connectionDetails <- connectionDetails
       args$cdmDatabaseSchema <- jobContext$moduleExecutionSettings$cdmDatabaseSchema