MaestroPipelineList {maestro} | R Documentation |
Class for a list of MaestroPipelines A MaestroPipelineList is created when there are multiple maestro pipelines in a single script
Class for a list of MaestroPipelines A MaestroPipelineList is created when there are multiple maestro pipelines in a single script
MaestroPipelines
list of pipelines
n_pipelines
number of pipelines in the list
new()
Create a MaestroPipelineList object
MaestroPipelineList$new(MaestroPipelines = list())
MaestroPipelines
list of MaestroPipelines
MaestroPipelineList
print()
Print the MaestroPipelineList
MaestroPipelineList$print()
add_pipelines()
Add pipelines to the list
MaestroPipelineList$add_pipelines(MaestroPipelines = NULL)
MaestroPipelines
list of MaestroPipelines
invisible
get_pipe_names()
Get names of the pipelines in the list
MaestroPipelineList$get_pipe_names()
character
get_schedule()
Get the schedule as a data.frame
MaestroPipelineList$get_schedule()
data.frame
get_timely_pipelines()
Get a new MaestroPipelineList containing only those pipelines scheduled to run
MaestroPipelineList$get_timely_pipelines(...)
...
arguments passed to self$check_timeliness
MaestroPipelineList
check_timeliness()
Check whether pipelines in the list are scheduled to run based on orchestrator frequency and current time
MaestroPipelineList$check_timeliness(...)
...
arguments passed to self$check_timeliness
logical
get_status()
Get status of the pipelines as a data.frame
MaestroPipelineList$get_status()
data.frame
get_errors()
Get list of errors from the pipelines
MaestroPipelineList$get_errors()
list
get_warnings()
Get list of warnings from the pipelines
MaestroPipelineList$get_warnings()
list
get_messages()
Get list of messages from the pipelines
MaestroPipelineList$get_messages()
list
get_artifacts()
Get artifacts (return values) from the pipelines
MaestroPipelineList$get_artifacts()
list
run()
Runs all the pipelines in the list
MaestroPipelineList$run(..., cores = 1L)
...
arguments passed to MaestroPipeline$run
cores
if using multicore number of cores to run in (uses furrr
)
invisible
clone()
The objects of this class are cloneable with this method.
MaestroPipelineList$clone(deep = FALSE)
deep
Whether to make a deep clone.