src/server/pkg/workload/workload.go
func RunWorkload(
	client *client.APIClient,
	rand *rand.Rand,
	size int,
) error {
	worker := newWorker(rand)
	for i := 0; i < size; i++ {
		if err := worker.work(client); err != nil {
			return err
		}
	}
	for _, job := range worker.startedJobs {
		jobInfo, err := client.InspectJob(job.ID, true)
		if err != nil {
			return err
		}
		if jobInfo.State != pps.JobState_JOB_SUCCESS {
			return fmt.Errorf("job %s failed", job.ID)
		}
	}
	return nil
}
func RunWorkload(
	client *client.APIClient,
	rand *rand.Rand,
	size int,
) error {
	worker := newWorker(rand)
	for i := 0; i < size; i++ {
		if err := worker.work(client); err != nil {
			return err
		}
	}
	for _, job := range worker.startedJobs {
		jobInfo, err := client.InspectJob(job.ID, true)
		if err != nil {
			return err
		}
		if jobInfo.State != pps.JobState_JOB_SUCCESS {
			return fmt.Errorf("job %s failed", job.ID)
		}
	}
	return nil
}
func RunWorkload ( client * client . APIClient , rand * rand . Rand , size int , ) error { worker := newWorker ( rand ) for i := 0 ; i < size ; i ++ { if err := worker . work ( client ) ; err != nil { return err } } for _ , job := range worker . startedJobs { jobInfo , err := client . InspectJob ( job . ID , true ) if err != nil { return err } if jobInfo . State != pps . JobState_JOB_SUCCESS { return fmt . Errorf ( " " , job . ID ) } } return nil }
// RunWorkload runs a test workload against a Pachyderm cluster.
RunWorkload runs a test workload against a Pachyderm cluster .