Function execute_pipeline 

pub fn execute_pipeline(
    rows: Vec<Row>,
    stages: &[String],
) -> Result<OutputResult>

Execute a pipeline starting from plain rows.

This is the lower-level row entrypoint used by tests and internal helpers. Like apply_pipeline, it starts with wants_copy = false.

Prefer apply_pipeline for the common “rows in, output out” path. This entrypoint is more useful when you want the execution wording to match the streaming variant below.

Examples

use osp_cli::dsl::execute_pipeline;
use osp_cli::row;

let output = execute_pipeline(
    vec![
        row! { "uid" => "bob" },
        row! { "uid" => "alice" },
    ],
    &["S uid".to_string()],
)?;

assert_eq!(output.as_rows().unwrap()[0]["uid"], "alice");