}
			if spec.Parallelism != nil && *spec.Parallelism > maxParallelismForIndexedJob {
				allErrs = append(allErrs, field.Invalid(fldPath.Child("parallelism"), *spec.Parallelism, fmt.Sprintf("must be less than or equal to %d when completion mode is %s", maxParallelismForIndexedJob, batch.IndexedCompletion)))
			}

                        throws InterruptedException {
                    setCorePoolSize(parallelism + parked.incrementAndGet());
                    try {
                        return super.invokeAll(tasks);
                    } finally {
                        setCorePoolSize(parallelism + parked.decrementAndGet());
                    }
                }
            };
        }

### `-tf-tpu-reorder-replicate-partitioned-inputs`

_Reorder replicated and partitioned input ops._

This pass rewrites how data parallelism and model parallelism is expressed for
inputs. It reorders `tf.TPUPartitionedInput` (model parallelism) and
`tf.TPUReplicatedInput` (data parallelism) ops. It transforms a DAG where
multiple `tf.TPUPartitionedInput` ops are feeding into a single

func (jm *Controller) manageJob(ctx context.Context, job *batch.Job, jobCtx *syncJobCtx) (int32, string, error) {
	logger := klog.FromContext(ctx)
	active := int32(len(jobCtx.activePods))
	parallelism := *job.Spec.Parallelism
	jobKey, err := controller.KeyFunc(job)
	if err != nil {
		utilruntime.HandleError(fmt.Errorf("Couldn't get key for job %#v: %v", job, err))
		return 0, metrics.JobSyncActionTracking, nil
	}

	return func(o *frameworkOptions) {
		o.extenders = extenders
	}
}

// WithParallelism sets parallelism for the scheduling frameworkImpl.
func WithParallelism(parallelism int) Option {
	return func(o *frameworkOptions) {
		o.parallelizer = parallelize.NewParallelizer(parallelism)
	}
}

// CaptureProfile is a callback to capture a finalized profile.

        "time": "2004-01-01T01:01:01Z",
        "fieldsType": "fieldsTypeValue",
        "fieldsV1": {},
        "subresource": "subresourceValue"
      }
    ]
  },
  "spec": {
    "parallelism": 1,
    "completions": 2,
    "activeDeadlineSeconds": 3,
    "podFailurePolicy": {
      "rules": [
        {
          "action": "actionValue",
          "onExitCodes": {

            "fieldsType": "fieldsTypeValue",
            "fieldsV1": {},
            "subresource": "subresourceValue"
          }
        ]
      },
      "spec": {
        "parallelism": 1,
        "completions": 2,
        "activeDeadlineSeconds": 3,
        "podFailurePolicy": {
          "rules": [
            {
              "action": "actionValue",
              "onExitCodes": {

        "time": "2004-01-01T01:01:01Z",
        "fieldsType": "fieldsTypeValue",
        "fieldsV1": {},
        "subresource": "subresourceValue"
      }
    ]
  },
  "spec": {
    "parallelism": 1,
    "completions": 2,
    "activeDeadlineSeconds": 3,
    "podFailurePolicy": {
      "rules": [
        {
          "action": "actionValue",
          "onExitCodes": {

            "fieldsType": "fieldsTypeValue",
            "fieldsV1": {},
            "subresource": "subresourceValue"
          }
        ]
      },
      "spec": {
        "parallelism": 1,
        "completions": 2,
        "activeDeadlineSeconds": 3,
        "podFailurePolicy": {
          "rules": [
            {
              "action": "actionValue",
              "onExitCodes": {

        "time": "2004-01-01T01:01:01Z",
        "fieldsType": "fieldsTypeValue",
        "fieldsV1": {},
        "subresource": "subresourceValue"
      }
    ]
  },
  "spec": {
    "parallelism": 1,
    "completions": 2,
    "activeDeadlineSeconds": 3,
    "podFailurePolicy": {
      "rules": [
        {
          "action": "actionValue",
          "onExitCodes": {