in perf-tools/framework/app_manager.go [287:304]
func (dam *DeploymentsAppManager) CreateWaitAndRefreshTasksStatus(schedulerName string, appInfo *AppInfo,
timeout time.Duration) error {
err := dam.Create(schedulerName, appInfo)
if err != nil {
return fmt.Errorf("failed to create app: %s", err.Error())
}
// wait for this app to be running (all pods are scheduled to be running)
err = dam.WaitForAppsToBeSatisfied(appInfo, timeout)
if err != nil {
return fmt.Errorf("failed to wait for this app to be running: %s", err.Error())
}
// refresh task status
err = dam.RefreshTasksStatusAfterRunning(appInfo)
if err != nil {
return fmt.Errorf("failed to refresh task status: %s", err.Error())
}
return nil
}