Skip to content

Commit 20ab78e

Browse files
committed
add .integrate stage in resolve_delayed_datasets
1 parent ed11cb1 commit 20ab78e

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

R/delayed_datasets.R

+10-1
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,16 @@ delayed_datasets <- function(x = "all") {
3737
#' @rdname delayed_datasets
3838
#' @export
3939
resolve_delayed_datasets <- function(des, datasets) {
40-
.resolve_delayed_datasets(.update_delayed_datasets(des, datasets))
40+
.integrate <- function(x) {
41+
if (inherits(x, "delayed_data_extract_spec")) return(x)
42+
if (checkmate::test_list(x, "list", len = 1L) &&
43+
checkmate::test_list(x[[1L]], "delayed_data_extract_spec")) {
44+
return(x[[1L]])
45+
}
46+
lapply(x, .integrate)
47+
}
48+
49+
.resolve_delayed_datasets(.update_delayed_datasets(des, datasets)) |> .integrate()
4150
}
4251

4352
#' @keywords internal

0 commit comments

Comments
 (0)