code: func JobHasDesiredParallelism(c ExtensionsInterface, job *extensions.Job) wait.ConditionFunc {
  
  	return func() (bool, error) {
  		job, err := c.Jobs(job.Namespace).Get(job.Name)
  		if err != nil {
  			return false, err
  		}
  
  		// desired parallelism can be either the exact number, in which case return immediately
  		if job.Status.Active == *job.Spec.Parallelism {
  			return true, nil
  		}
  		if job.Spec.Completions == nil {
  			// A job without specified completions needs to wait for Active to reach Parallelism.
  			return false, nil
  		} else {
  			// otherwise count successful
  			progress := *job.Spec.Completions - job.Status.Active - job.Status.Succeeded
  			return progress == 0, nil
  		}
  	}
  }
docs: // JobHasDesiredParallelism returns a condition that will be true if the desired parallelism count
  // for a job equals the current active counts or is less by an appropriate successful/unsuccessful count.