inst/do_job.R

#! /usr/bin/Rscript
cat(Sys.getpid())

suppressPackageStartupMessages(library(RzmqJobQueue))
library(RzmqJobQueue)
argv <- commandArgs(trailingOnly=TRUE)
init_worker(argv[1], argv[2])
while(TRUE) {
  do_job(argv[1], argv[2])
}
wush978/RzmqJobQueue documentation built on May 4, 2019, 12:02 p.m.