tests/testthat/test_pipelines_dags_run_bad/dag_with_error.R

In maestro: Orchestration of Data Pipelines

# Simple 1 -> 1 -----------------------------------------------------------
#' @maestroInputs get_num
multiply <- function(.input) {
  .input * 4
}

#' @maestroFrequency daily
#' @maestroOutputs multiply
get_num <- function() {
  stop("oops")
}