Skip to content

Commit e103851

Browse files
Merge branch 'develop' of github.com:futureverse/future.batchtools into develop
2 parents bed44bc + f974db0 commit e103851

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

R/BatchtoolsFutureBackend-class.R

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -766,9 +766,17 @@ await <- function(future, cleanup = TRUE, ...) {
766766
## Sleep function - increases geometrically as a function of iterations
767767
sleep_fcn <- function(i) delta * alpha ^ (i - 1)
768768

769+
if (debug) mdebugf_push("batchtools::waitForJobs(..., timeout = %s) ...", timeout)
769770
res <- waitForJobs(ids = jobid, timeout = timeout, sleep = sleep_fcn,
770771
stop.on.error = FALSE, reg = reg)
771-
if (debug) mdebugf("batchtools::waitForJobs(): %s", res)
772+
if (!isTRUE(res)) {
773+
warning(FutureWarning(sprintf("batchtools::waitForJobs(..., timeout = %s) returned FALSE", timeout), future = future))
774+
}
775+
if (debug) {
776+
mdebugf("Result: %s", res)
777+
mdebugf_pop()
778+
}
779+
772780
stat <- status(future)
773781
if (debug) {
774782
mdebugf("status(): %s", paste(sQuote(stat), collapse = ", "))

0 commit comments

Comments
 (0)