pipeflow (version 0.2.2)

pipe_get_depends: Get step dependencies

Description

Get step dependencies

Usage

pipe_get_depends(pip)
pipe_get_depends_down(pip, step, recursive = TRUE)
pipe_get_depends_up(pip, step, recursive = TRUE)

Value

• pipe_get_depends: named list of dependencies for each step

• pipe_get_depends_down: list of downstream dependencies

• pipe_get_depends_up: list of downstream dependencies

Arguments

pip

Pipeline object

step

string name of step

recursive

logical if TRUE, dependencies of dependencies are also returned.

Methods

• pipe_get_depends: get all dependencies for all steps defined in the pipeline

• pipe_get_depends_down: get all downstream dependencies of a given step, by default descending recursively.

• pipe_get_depends_up: get all upstream dependencies of a given step, by default descending recursively.

Examples

# pipe_get_depends
p <- pipe_new("pipe", data = 1:2)
pipe_add(p, "add1", \(x = ~data) x + 1)
pipe_add(p, "add2", \(x = ~data, y = ~add1) x + y)
pipe_get_depends(p)

# pipe_get_depends_down
p <- pipe_new("pipe", data = 1:2)
pipe_add(p, "add1", \(x = ~data) x + 1)
pipe_add(p, "add2", \(x = ~data, y = ~add1) x + y)
pipe_add(p, "mult3", \(x = ~add1) x * 3)
pipe_add(p, "mult4", \(x = ~add2) x * 4)
pipe_get_depends_down(p, "add1")
pipe_get_depends_down(p, "add1", recursive = FALSE)

# pipe_get_depends_up
p <- pipe_new("pipe", data = 1:2)
pipe_add(p, "add1", \(x = ~data) x + 1)
pipe_add(p, "add2", \(x = ~data, y = ~add1) x + y)
pipe_add(p, "mult3", \(x = ~add1) x * 3)
pipe_add(p, "mult4", \(x = ~add2) x * 4)
pipe_get_depends_up(p, "mult4")
pipe_get_depends_up(p, "mult4", recursive = FALSE)