qsubRun: Submit command-line tools to cluster

In systemPipeR: systemPipeR: NGS workflow and report generation environment

Description

Note: This function as been deprecated. Please use clusterRun instead. qsubRun submits command-line tools to queue (e.g. Torque) of compute cluster using run specifications defined by runX and getQsubargs functions.

Usage

qsubRun(appfct="runCommandline(args=args, runid='01')", args, qsubargs, Nqsubs = 1, package = "systemPipeR", shebang="#!/bin/bash")

Arguments

appfct	Accpets runX functions, such as appfct="runCommandline(args, runid)"
args	Argument list returned by systemArgs().
qsubargs	Argument list returned by getQsubargs().
Nqsubs	Interger defining the number of qsub processes. Note: the function will not assign more qsub processes than there are FASTQ files. E.g. if there are 10 FASTQ files and Nqsubs=20 then the function will generate only 10 qsub processes. To increase the number of CPU cores used by each process, one can increase the p value under systemArgs().
package	Package to load. Name provided as character vector of length one. Default is sytemPipeR.
shebang	defines shebang (fist line) used in submission shell script; default is set to #!/bin/bash.

Value

Returns list where list components contain FASTQ file names and their names are the qsub process IDs assiged by the queuing system. In addition, three files will be generated for each qsub submission process: submitargs0X (R object containing appargs), submitargs0X.R (R script using appargs) and submitargs0X.sh (shell submission script). In addition, the chosen runX function will output a submitargs0X_log file for each qsub process containing the executable commands processed by each qsub instance.

Author(s)

Thomas Girke

Examples

## Construct SYSargs object from param and targets files 
param <- system.file("extdata", "tophat.param", package="systemPipeR")
targets <- system.file("extdata", "targets.txt", package="systemPipeR")
args <- systemArgs(sysma=param, mytargets=targets)
args
names(args); modules(args); cores(args); outpaths(args); sysargs(args)

## Not run: 
## Execute SYSargs on single machine
runCommandline(args=args)

## Execute SYSargs on multiple machines  
qsubargs <- getQsubargs(queue="batch", Nnodes="nodes=1", cores=cores(tophat), memory="mem=10gb", time="walltime=20:00:00")
qsubRun(args=args, qsubargs=qsubargs, Nqsubs=1, package="systemPipeR")
## Alignment stats
read_statsDF <- alignStats(fqpaths=tophatargs$infile1, bampaths=bampaths, fqgz=TRUE) 
read_statsDF <- cbind(read_statsDF[targets$FileName,], targets)
write.table(read_statsDF, "results/alignStats.xls", row.names=FALSE, quote=FALSE, sep="\t")

## End(Not run)

systemPipeR documentation built on Jan. 26, 2021, 2 a.m.