Manually run a pipeline regardless of schedule

Instantly run a single pipeline from the schedule. This is useful for testing purposes or if you want to just run something one-off.

Usage

invoke(schedule, pipe_name, resources = list(), ...)

Arguments

schedule: object of type MaestroSchedule created using build_schedule()
pipe_name: name of a single pipe name from the schedule
resources: named list of shared resources made available to pipelines as needed
...: other arguments passed to run_schedule()

Value

invisible

Details

Scheduling parameters such as the frequency, start time, and specifiers are ignored. The pipeline will be run even if maestroSkip is present.

Examples

if (interactive()) {
  pipeline_dir <- tempdir()
  create_pipeline("my_new_pipeline", pipeline_dir, open = FALSE)
  schedule <- build_schedule(pipeline_dir = pipeline_dir)

  invoke(schedule, "my_new_pipeline")
}