tests/testthat/test_pipelines_fan_in/fanin.R

In maestro: Orchestration of Data Pipelines

#' @maestroFrequency daily
letter_a <- function() {
  'a'
}

#' @maestroFrequency daily
letter_b <- function() {
  'b'
}
  
#' @maestroInputs collect(letter_a, letter_b)
ab <- function(.input) {
  paste0(.input$letter_a, .input$letter_b)
}