Struct Pipeline 

pub struct Pipeline { /* private fields */ }

Builder over a sequence of Callables.

Implementations

impl Pipeline

pub fn from(c: CallableHandle) -> Self

pub fn then(self, c: CallableHandle) -> Self

prompt | model — chain another stage.

pub fn passthrough(self) -> Self

Pass input through unchanged. Useful as a starting node.

pub fn assign(self, key: impl Into<String>, c: CallableHandle) -> Self

RunnablePassthrough.assign(key=fn) — run c on the current input and add the result under key, leaving original input fields intact.

pub fn fan_out_with(self, branches: Vec<(String, CallableHandle)>) -> Self

RunnableParallel({a: ca, b: cb}) as an inline stage. Each branch runs concurrently on the current input; output is a JSON object keyed by branch name.

pub fn build(self) -> CallableHandle