Function run_pipeline

Source
pub async fn run_pipeline(ctx: Arc<WatchContext>) -> Result<()>