Skip to content

Instantly share code, notes, and snippets.

@jakob-r
Last active October 19, 2015 16:55
Show Gist options
  • Save jakob-r/2fcdbee75b81b4716d8c to your computer and use it in GitHub Desktop.
Save jakob-r/2fcdbee75b81b4716d8c to your computer and use it in GitHub Desktop.
BatchJobs: Automaticly submit expired jobs
waitAndSubmitExpired = function(reg, resources, wait = 30, ...) {
done.ids = findDone(reg)
error.ids = findErrors(reg)
expired.ids = findExpired(reg)
submitted.ids = findSubmitted(reg)
restarted.ids = numeric()
while (!all(submitted.ids %in% c(done.ids, error.ids))) {
if (length(expired.ids) > 0)
submitJobs(reg, expired.ids, resources = resources, ...)
restarted.ids = c(restarted.ids, expired.ids)
Sys.sleep(time = wait)
done.ids = findDone(reg)
error.ids = findErrors(reg)
expired.ids = findExpired(reg)
}
invisible()
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment