Skip to content

Commit 07da369

Browse files
TESTS: Add tests for cancel()
1 parent f95831e commit 07da369

File tree

3 files changed

+33
-2
lines changed

3 files changed

+33
-2
lines changed

NEWS.md

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,10 +8,12 @@
88

99
## Test Updates
1010

11+
* Add tests for `cancel()`.
12+
1113
* Under development:
1214

1315
- Assert that `plan()` accepts argument `interrupts`.
14-
16+
1517

1618
# Version 0.9.0 [2025-04-14]
1719

inst/test-db/cancel.R

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
make_test(title = "cancel()", args = list(lazy = c(FALSE, TRUE)), tags = c("cancel"), {
2+
f <- future({
3+
Sys.sleep(0.5)
4+
list(a = 1, b = 42L)
5+
}, lazy = lazy)
6+
7+
f0 <- future(NULL)
8+
v <- value(f0)
9+
10+
cat(sprintf("state = %s\n", sQuote(f[["state"]])))
11+
if (lazy) {
12+
stopifnot(f[["state"]] %in% "created")
13+
} else {
14+
stopifnot(f[["state"]] %in% c("submitted", "running", "finished"))
15+
}
16+
17+
f <- cancel(f)
18+
cat(sprintf("state = %s\n", sQuote(f[["state"]])))
19+
if (lazy) {
20+
stopifnot(f[["state"]] %in% "created")
21+
} else {
22+
stopifnot(f[["state"]] %in% c("canceled", "finished"))
23+
}
24+
25+
## A canceled future may be resolved or not, which
26+
## depends on future been interrupted or not
27+
r <- resolved(f)
28+
cat(sprintf("resolved = %s\n", sQuote(r)))
29+
})

man/make_test.Rd

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)