R/submit-local.R

In flow-r/flowr: Streamlining Design and Deployment of Complex Workflows

## start small, might become more interesting
run_local <- function(x, jobj, cores = opts_flow$get("local_cores"), execute){
	message("\nWorking on: ", jobj@name)
	if(!execute)
		return(rep(0, length(x)))
	## --- force cores to be 1 IF serial 
	if(jobj@submission_type == "serial")
		cores = 1
	ret <- mclapply(x, system, intern = TRUE, mc.cores = cores)
	return(unlist(ret))
}