pub async fn run_pipeline(
statements: &[Vec<ExecStage>],
ctx: &ExecContext,
timeout: Option<Duration>,
) -> Result<ExecOutput, String>pub async fn run_pipeline(
statements: &[Vec<ExecStage>],
ctx: &ExecContext,
timeout: Option<Duration>,
) -> Result<ExecOutput, String>