run_pipeline

Function run_pipeline 

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