pub async fn run_streamling( pipeline_path: &Path, binary_path: Option<&Path>, env_vars: &[(String, String)], ) -> Result<ExitStatus>
Run the streamling binary with the given pipeline file