pipe_run_step {pipeflow} | R Documentation |
Run specific step
Description
Run given pipeline step possibly together with upstream and/or downstream dependencies.
Usage
pipe_run_step(
pip,
step,
upstream = TRUE,
downstream = FALSE,
cleanUnkept = FALSE
)
Arguments
pip |
|
step |
|
upstream |
|
downstream |
|
cleanUnkept |
|
Value
returns the Pipeline
object invisibly
Examples
p <- pipe_new("pipe", data = 1)
pipe_add(p, "add1", \(x = ~data, y = 1) x + y)
pipe_add(p, "add2", \(x = ~add1, z = 2) x + z)
pipe_add(p, "mult", \(x = ~add1, y = ~add2) x * y)
pipe_run_step(p, "add2")
pipe_run_step(p, "add2", downstream = TRUE)
pipe_run_step(p, "mult", upstream = TRUE)
[Package pipeflow version 0.2.2 Index]