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