pub async fn drive_progress<T>( client: &mut T, run_id: &RunId, worker_names: Vec<String>, ) -> Result<()>where T: ProgressFetcher,