Gets the controllers for the pipeline.
Value
A named list of crew_class_controller objects, where each
controller corresponds to a step in the pipeline.
Examples
pipeline <- example_pipeline(type = "MultiSampleSCPipeline")
#> Writing configuration parameters to: /tmp/RtmpA5lNG6/file3290372e1b8/config_file_12944.json
#> Configured steps:
#> barcode_demultiplex: TRUE
#> genome_alignment: TRUE
#> gene_quantification: TRUE
#> isoform_identification: TRUE
#> read_realignment: TRUE
#> transcript_quantification: TRUE
#> samtools not found, will use Rsamtools package instead
controllers(pipeline) # get the controllers
#> $default
#> <crew_class_controller>
#> Public:
#> autoscale: function (controllers = NULL)
#> autoscaling: active binding
#> backlog: active binding
#> backup: active binding
#> cancel: function (names = character(0L), all = FALSE)
#> client: active binding
#> collect: function (scale = TRUE, throttle = TRUE, error = NULL, controllers = NULL)
#> crashes: function (name, controllers = NULL)
#> crashes_max: active binding
#> descale: function (controllers = NULL)
#> empty: function (controllers = NULL)
#> error: active binding
#> garbage_collection: active binding
#> initialize: function (client = NULL, launcher = NULL, reset_globals = NULL,
#> launch: function (n = 1L, controllers = NULL)
#> launcher: active binding
#> map: function (command, iterate, data = list(), globals = list(),
#> nonempty: function (controllers = NULL)
#> pids: function (controllers = NULL)
#> pop: function (scale = TRUE, collect = NULL, throttle = TRUE, error = NULL,
#> pop_backlog: function (controllers = NULL)
#> popped: active binding
#> promise: function (mode = "one", seconds_interval = 1, scale = NULL, throttle = NULL,
#> push: function (command, data = list(), globals = list(), substitute = TRUE,
#> push_backlog: function (name, controller = NULL)
#> pushed: active binding
#> queue: active binding
#> reset_globals: active binding
#> reset_options: active binding
#> reset_packages: active binding
#> resolved: function (controllers = NULL)
#> saturated: function (collect = NULL, throttle = NULL, controller = NULL)
#> scale: function (throttle = TRUE, controllers = NULL)
#> start: function (controllers = NULL)
#> started: function (controllers = NULL)
#> summary: function (controllers = NULL)
#> tasks: active binding
#> terminate: function (controllers = NULL)
#> unpopped: function (controllers = NULL)
#> unresolved: function (controllers = NULL)
#> validate: function ()
#> wait: function (mode = "all", seconds_interval = NULL, seconds_timeout = Inf,
#> walk: function (command, iterate, data = list(), globals = list(),
#> Private:
#> .autoscaling: FALSE
#> .backlog: NULL
#> .backup: NULL
#> .client: crew_class_client, R6
#> .crash_log: environment
#> .crashes_max: 5
#> .error: NULL
#> .garbage_collection: FALSE
#> .launcher: crew_class_launcher_local, crew_class_launcher, R6
#> .name_new_task: function (name)
#> .popped: 0
#> .push_task: function (name, task)
#> .pushed: 0
#> .queue: NULL
#> .register_started: function ()
#> .reset_globals: TRUE
#> .reset_options: FALSE
#> .reset_packages: FALSE
#> .resolve: function (force)
#> .resolved: -1
#> .scan_crash: function (name, task)
#> .summary: NULL
#> .tasks: environment
#> .wait_all_once: function ()
#> .wait_one_once: function ()
#>