Print plan() for 'batchtools_sge' reports on SGE version

Author: HenrikBengtsson

DESCRIPTION

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

NAMESPACE

@@ -14,6 +14,7 @@ S3method(nbrOfWorkers,BatchtoolsMulticoreFutureBackend)
 S3method(nbrOfWorkers,BatchtoolsUniprocessFutureBackend)
 S3method(print,BatchtoolsFuture)
 S3method(print,BatchtoolsFutureBackend)
+S3method(print,BatchtoolsSGEFutureBackend)
 S3method(registerFuture,BatchtoolsFuture)
 S3method(registerFuture,BatchtoolsUniprocessFuture)
 S3method(registerFuture,default)

NEWS.md

@@ -33,6 +33,8 @@
    specified, corresponding `module load <name>` entries are injected
    to the job script.
 
+ * Print `plan()` for `batchtools_sge` reports on SGE version.
+
 ## Documentation
 
  * Add `timeout <runtime> ...` to the default `batchtools_bash`

R/BatchtoolsFutureBackend-class.R

@@ -151,6 +151,9 @@ print.BatchtoolsFutureBackend <- function(x, ...) {
   path <- future_cache_path()
   printf("Cache directory: %s\n", dir_info(path))
 
+  printf("batchtools resources:\n")
+  str(resources)
+
   invisible(x)
 }
 

R/batchtools_sge.R

@@ -6,6 +6,15 @@ BatchtoolsSGEFutureBackend <- function(...) {
   core
 }
 
+#' @export
+#' @keywords internal
+print.BatchtoolsSGEFutureBackend <- function(x, ...) {  
+  NextMethod()
+  printf("SGE version: %s\n", sge_version())
+  invisible(x)
+}
+
+
 #' A batchtools SGE backend resolves futures in parallel via a SGE job scheduler
 #'
 #' @inheritParams BatchtoolsTemplateFutureBackend
@@ -79,3 +88,29 @@ attr(batchtools_sge, "tweakable") <- c(
 )
 attr(batchtools_sge, "init") <- TRUE
 attr(batchtools_sge, "factory") <- BatchtoolsSGEFutureBackend
+
+
+sge_version <- local({
+  version <- NULL
+  
+  function() {
+    if (is.null(version)) {
+      out <- tryCatch(system2("qstat", args = c("-help"), stdout = TRUE, stderr = TRUE), error = identity)
+      if (inherits(out, "error")) {
+        version <<- "N/A (unexpected output from 'qstat -help')"
+      } else {
+        status <- attr(out, "status")
+        if (!is.null(status) && status != 0) {
+          version <<- "N/A (unexpected output from 'qstat -help')"
+        } else {
+          out <- gsub("(^[[:blank:]]+|[[:blank:]]+$)", "", out)
+          out <- out[nzchar(out)]
+          if (length(out) >= 1) {
+            version <<- out[1]
+          }
+        }
+      }
+    }
+    version
+  }
+})