Kill some jobs on the batch system.
Kill jobs which have already been submitted to the batch system. If a job is killed its internal state is reset as if it had not been submitted at all.
The function informs if (a) the job you want to kill has not been submitted, (b) the job has already terminated, (c) for some reason no batch job id is available. In all 3 cases above, nothing is changed for the state of this job and no call to the internal kill cluster function is generated.
In case of an error when killing, the function tries - after a short sleep - to kill the remaining batch jobs again. If this fails again for some jobs, the function gives up. Only jobs that could be killed are reset in the DB.
integer]. Ids of killed jobs.
1 2 3 4 5 6 7 8 9 10 11 12 13
## Not run: reg = makeRegistry(id = "BatchJobsExample", file.dir = tempfile(), seed = 123) f = function(x) Sys.sleep(x) batchMap(reg, f, 1:10 + 5) submitJobs(reg) waitForJobs(reg) # kill all jobs currently _running_ killJobs(reg, findRunning(reg)) # kill all jobs queued or running killJobs(reg, findNotTerminated(reg)) ## End(Not run)
Want to suggest features or report bugs for rdrr.io? Use the GitHub issue tracker.