tests/testthat/test_pipelines_fan_out_collect/fan_out_collect.R

In maestro: Orchestration of Data Pipelines

#' @maestroFrequency daily
numbers <- function() {
  1:3
}

#' @maestroInputs numbers
#' @maestroMap
multiply <- function(.input) {
  .input * 3
}

#' @maestroInputs collect(multiply)
add <- function(.input) {
  sum(unlist(.input))
}