pipeline.current
Easy access to active pipelines, state, sources and schemas
pipeline
def pipeline() -> _Pipeline
Currently active pipeline ie. the most recently created or run
Easy access to active pipelines, state, sources and schemas
def pipeline() -> _Pipeline
Currently active pipeline ie. the most recently created or run