Learn R Programming

⚠️There's a newer version (0.9.18) of this package.Take me there.

batchtools

As a successor of the packages BatchJobs and BatchExperiments, batchtools provides a parallel implementation of Map for high performance computing systems managed by schedulers like Slurm, Sun Grid Engine, OpenLava, TORQUE/OpenPBS, Load Sharing Facility (LSF) or Docker Swarm (see the setup section in the vignette).

Main features:

  • Convenience: All relevant batch system operations (submitting, listing, killing) are either handled internally or abstracted via simple R functions
  • Portability: With a well-defined interface, the source is independent from the underlying batch system - prototype locally, deploy on any high performance cluster
  • Reproducibility: Every computational part has an associated seed stored in a data base which ensures reproducibility even when the underlying batch system changes
  • Abstraction: The code layers for algorithms, experiment definitions and execution are cleanly separated and allow to write readable and maintainable code to manage large scale computer experiments

Installation

Install the stable version from CRAN:

install.packages("batchtools")

For the development version, use devtools:

devtools::install_github("mllg/batchtools")

Next, you need to setup batchtools for your HPC (it will run sequentially otherwise). See the vignette for instructions.

Why batchtools?

The development of BatchJobs and BatchExperiments is discontinued for the following reasons:

  • Maintainability: The packages BatchJobs and BatchExperiments are tightly connected which makes maintenance difficult. Changes have to be synchronized and tested against the current CRAN versions for compatibility. Furthermore, BatchExperiments violates CRAN policies by calling internal functions of BatchJobs.
  • Data base issues: Although we invested weeks to mitigate issues with locks of the SQLite data base or file system (staged queries, file system timeouts, ...), BatchJobs kept working unreliable on some systems with high latency under certain conditions. This made BatchJobs unusable for many users.

BatchJobs and BatchExperiments will remain on CRAN, but new features are unlikely to be ported back. The vignette contains a section comparing the packages.

Resources

Citation

Please cite the JOSS paper using the following BibTeX entry:

@article{,
  doi = {10.21105/joss.00135},
  url = {https://doi.org/10.21105/joss.00135},
  year  = {2017},
  month = {feb},
  publisher = {The Open Journal},
  volume = {2},
  number = {10},
  author = {Michel Lang and Bernd Bischl and Dirk Surmann},
  title = {batchtools: Tools for R to work on batch systems},
  journal = {The Journal of Open Source Software}
}

Related Software

  • The High Performance Computing Task View lists the most relevant packages for scientific computing with R.
  • clustermq is a similar approach which also supports multiple schedulers. Uses the ZeroMQ network protocol for communication, and shines if you have millions of fast jobs.
  • batch assists in splitting and submitting jobs to LSF and MOSIX clusters.
  • flowr supports LSF, Slurm, TORQUE and Moab and provides a scatter-gather approach to define computational jobs.
  • future.batchtools implements batchtools as backend for future.
  • doFuture together with future.batchtools connects batchtools to foreach.
  • drake uses graphs to define computational jobs. batchtools is used as a backend via future.batchtools.

Contributing to batchtools

This R package is licensed under the LGPL-3. If you encounter problems using this software (lack of documentation, misleading or wrong documentation, unexpected behaviour, bugs, ...) or just want to suggest features, please open an issue in the issue tracker. Pull requests are welcome and will be included at the discretion of the author. If you have customized a template file for your (larger) computing site, please share it: fork the repository, place your template in inst/templates and send a pull request.

Copy Link

Version

Install

install.packages('batchtools')

Monthly Downloads

5,126

Version

0.9.16

License

LGPL-3

Issues

Pull Requests

Stars

Forks

Maintainer

Michel Lang

Last Published

February 3rd, 2023

Functions in batchtools (0.9.16)

JoinTables

Inner, Left, Right, Outer, Semi and Anti Join for Data Tables
JobNames

Set and Retrieve Job Names
addExperiments

Add Experiments to the Registry
addAlgorithm

Define Algorithms for Experiments
makeJob

Jobs and Experiments
makeJobCollection

JobCollection Constructor
batchReduce

Reduce Operation for Batch Systems
cfReadBrewTemplate

Cluster Functions Helper to Parse a Brew Template
cfBrewTemplate

Cluster Functions Helper to Write Job Description Files
batchExport

Export Objects to the Slaves
cfHandleUnknownSubmitError

Cluster Functions Helper to Handle Unknown Errors
batchtools-package

batchtools: Tools for Computation on Batch Systems
batchMap

Map Operation for Batch Systems
cfKillJob

Cluster Functions Helper to Kill Batch Jobs
batchMapResults

Map Over Results to Create New Jobs
btlapply

Synchronous Apply Functions
getErrorMessages

Retrieve Error Messages
doJobCollection

Execute Jobs of a JobCollection
chunk

Chunk Jobs for Sequential Execution
execJob

Execute a Single Jobs
getDefaultRegistry

Get and Set the Default Registry
findJobs

Find and Filter Jobs
clearRegistry

Remove All Jobs
findConfFile

Find a batchtools Configuration File
estimateRuntimes

Estimate Remaining Runtimes
findTemplateFile

Find a batchtools Template File
makeClusterFunctions

ClusterFunctions Constructor
getJobTable

Query Job Information
getStatus

Summarize the Computational Status
makeClusterFunctionsDocker

ClusterFunctions for Docker
killJobs

Kill Jobs
grepLogs

Grep Log Files for a Pattern
loadRegistry

Load a Registry from the File System
loadResult

Load the Result of a Single Job
makeClusterFunctionsLSF

ClusterFunctions for LSF Systems
makeClusterFunctionsInteractive

ClusterFunctions for Sequential Execution in the Running R Session
makeClusterFunctionsSocket

ClusterFunctions for Parallel Socket Execution
makeClusterFunctionsSSH

ClusterFunctions for Remote SSH Execution
makeExperimentRegistry

ExperimentRegistry Constructor
makeClusterFunctionsSlurm

ClusterFunctions for Slurm Systems
makeClusterFunctionsSGE

ClusterFunctions for SGE Systems
makeClusterFunctionsTORQUE

ClusterFunctions for OpenPBS/TORQUE Systems
makeSubmitJobResult

Create a SubmitJobResult
makeClusterFunctionsMulticore

ClusterFunctions for Parallel Multicore Execution
makeRegistry

Registry Constructor
makeClusterFunctionsOpenLava

ClusterFunctions for OpenLava
removeRegistry

Remove a Registry from the File System
showLog

Inspect Log Files
submitJobs

Submit Jobs to the Batch Systems
removeExperiments

Remove Experiments
reduceResults

Reduce Results
summarizeExperiments

Quick Summary over Experiments
reduceResultsList

Apply Functions on Results
sweepRegistry

Check Consistency and Remove Obsolete Information
unwrap

Unwrap Nested Data Frames
waitForJobs

Wait for Termination of Jobs
saveRegistry

Store the Registy to the File System
runOSCommand

Run OS Commands on Local or Remote Machines
testJob

Run Jobs Interactively
resetJobs

Reset the Computational State of Jobs
syncRegistry

Synchronize the Registry
runHook

Trigger Evaluation of Custom Function
Tags

Add or Remove Job Tags
Worker

Create a Linux-Worker
addProblem

Define Problems for Experiments
assertRegistry

assertRegistry