More informative info gathered for examples

Author: HenrikBengtsson

DESCRIPTION

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

R/batchtools_bash.R

@@ -63,9 +63,16 @@ BatchtoolsBashFutureBackend <- function(..., template = "bash", fs.latency = 0.0
 #'
 #' message("Main process ID: ", Sys.getpid())
 #'
-#' f <- future(Sys.getpid())
-#' pid <- value(f)
-#' message("Worker process ID: ", pid)
+#' f <- future({
+#'   data.frame(
+#'     hostname = Sys.info()[["nodename"]],
+#'           os = Sys.info()[["sysname"]],
+#'        cores = unname(parallelly::availableCores()),
+#'          pid = Sys.getpid()
+#'   )
+#' })
+#' info <- value(f)
+#' print(info)
 #' 
 #' @export
 batchtools_bash <- function(..., template = "bash", fs.latency = 0.0, resources = list()) {

R/batchtools_interactive.R

@@ -47,9 +47,16 @@ BatchtoolsInteractiveFutureBackend <- function(fs.latency = 0.0, ...) {
 #'
 #' message("Main process ID: ", Sys.getpid())
 #'
-#' f <- future(Sys.getpid())
-#' pid <- value(f)
-#' message("Worker process ID: ", pid)
+#' f <- future({
+#'   data.frame(
+#'     hostname = Sys.info()[["nodename"]],
+#'           os = Sys.info()[["sysname"]],
+#'        cores = unname(parallelly::availableCores()),
+#'          pid = Sys.getpid()
+#'   )
+#' })
+#' info <- value(f)
+#' print(info)
 #' 
 #' @inheritParams BatchtoolsInteractiveFutureBackend
 #'

R/batchtools_local.R

@@ -79,9 +79,16 @@ BatchtoolsLocalFutureBackend <- function(fs.latency = 0.0, ...) {
 #'
 #' message("Main process ID: ", Sys.getpid())
 #'
-#' f <- future(Sys.getpid())
-#' pid <- value(f)
-#' message("Worker process ID: ", pid)
+#' f <- future({
+#'   data.frame(
+#'     hostname = Sys.info()[["nodename"]],
+#'           os = Sys.info()[["sysname"]],
+#'        cores = unname(parallelly::availableCores()),
+#'          pid = Sys.getpid()
+#'   )
+#' })
+#' info <- value(f)
+#' print(info)
 #' 
 #' @export
 batchtools_local <- function(..., fs.latency = 0.0) {

R/batchtools_lsf.R

@@ -44,7 +44,13 @@ BatchtoolsLsfFutureBackend <- function(...) {
 #'   asis = c("-n 4", "-R 'span[hosts=1]'", "-q freecycle")
 #' ))
 #'
-#' f <- future(Sys.info())
+#' f <- future({
+#'   data.frame(
+#'     hostname = Sys.info()[["nodename"]],
+#'           os = Sys.info()[["sysname"]],
+#'        cores = unname(parallelly::availableCores())
+#'   )
+#' })
 #' info <- value(f)
 #' print(info)
 #' 

R/batchtools_multicore.R

@@ -90,9 +90,16 @@ BatchtoolsMulticoreFutureBackend <- function(workers = availableCores(constraint
 #'
 #' message("Main process ID: ", Sys.getpid())
 #'
-#' f <- future(Sys.getpid())
-#' pid <- value(f)
-#' message("Worker process ID: ", pid)
+#' f <- future({
+#'   data.frame(
+#'     hostname = Sys.info()[["nodename"]],
+#'           os = Sys.info()[["sysname"]],
+#'        cores = unname(parallelly::availableCores()),
+#'          pid = Sys.getpid()
+#'   )
+#' })
+#' info <- value(f)
+#' print(info)
 #' 
 #' @export
 batchtools_multicore <- function(..., workers = availableCores(constraints = "multicore"), fs.latency = 0.0) {

R/batchtools_openlava.R

@@ -44,7 +44,13 @@ BatchtoolsOpenLavaFutureBackend <- function(...) {
 #'   asis = c("-n 4", "-R 'span[hosts=1]'", "-q freecycle")
 #' ))
 #'
-#' f <- future(Sys.info())
+#' f <- future({
+#'   data.frame(
+#'     hostname = Sys.info()[["nodename"]],
+#'           os = Sys.info()[["sysname"]],
+#'        cores = unname(parallelly::availableCores())
+#'   )
+#' })
 #' info <- value(f)
 #' print(info)
 #'

R/batchtools_sge.R

@@ -48,7 +48,13 @@ BatchtoolsSGEFutureBackend <- function(...) {
 #'   asis = c("-pe smp 4", "-q freecycle.q")
 #' ))
 #'
-#' f <- future(Sys.info())
+#' f <- future({
+#'   data.frame(
+#'     hostname = Sys.info()[["nodename"]],
+#'           os = Sys.info()[["sysname"]],
+#'        cores = unname(parallelly::availableCores())
+#'   )
+#' })
 #' info <- value(f)
 #' print(info)
 #' 

R/batchtools_slurm.R

@@ -49,7 +49,13 @@ BatchtoolsSlurmFutureBackend <- function(...) {
 #'   asis = c("--nodes=1", "--ntasks=4", "--partition=freecycle")
 #' ))
 #'
-#' f <- future(Sys.info())
+#' f <- future({
+#'   data.frame(
+#'     hostname = Sys.info()[["nodename"]],
+#'           os = Sys.info()[["sysname"]],
+#'        cores = unname(parallelly::availableCores())
+#'   )
+#' })
 #' info <- value(f)
 #' print(info)
 #'

R/batchtools_torque.R

@@ -43,7 +43,13 @@ BatchtoolsTorqueFutureBackend <- function(...) {
 #'   asis = c("-l nodes=1:ppn=4", "-q freecycle")
 #' ))
 #'
-#' f <- future(Sys.info())
+#' f <- future({
+#'   data.frame(
+#'     hostname = Sys.info()[["nodename"]],
+#'           os = Sys.info()[["sysname"]],
+#'        cores = unname(parallelly::availableCores())
+#'   )
+#' })
 #' info <- value(f)
 #' print(info)
 #'