Extract Upstream Subgraph
Returns a new pipeline containing the named node and all of its transitive dependencies (ancestors in the DAG).
p (Pipeline): The
pipeline.
name (String): The name of the
target node.
A new pipeline with only the node and its ancestors.
p |> upstream_of("predictions")