Skip to content

Commit 397f22b

Browse files
Tweaks for 'earlySignal'
1 parent 6811016 commit 397f22b

File tree

2 files changed

+3
-7
lines changed

2 files changed

+3
-7
lines changed

R/backend_api-SequentialFutureBackend-class.R

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,6 @@ launchFuture.SequentialFutureBackend <- function(backend, future, ...) {
3030
## Apply backend tweaks
3131
split <- backend[["split"]]
3232
if (!is.null(split)) data[["capture"]][["split"]] <- split
33-
earlySignal <- backend[["earlySignal"]]
34-
if (!is.null(earlySignal)) future[["earlySignal"]] <- earlySignal
3533

3634
## Launch future
3735
future[["state"]] <- "running"

R/utils-signalEarly.R

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,10 @@
11
signalEarly <- function(future, collect = TRUE, .signalEarly = TRUE, ...) {
2+
## Don't signal early?
3+
if (!isTRUE(future[["earlySignal"]])) return(future)
4+
25
## Future is not yet launched
36
if (future[["state"]] == "created") return(future)
47

5-
earlySignal <- future[["earlySignal"]]
6-
7-
## Don't signal early?
8-
if (!earlySignal) return(future)
9-
108
debug <- isTRUE(getOption("future.debug"))
119
if (debug) mdebug("signalEarly() ...")
1210

0 commit comments

Comments
 (0)