- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for Parallelism (0.32 sec)
-
pkg/controller/job/job_controller_test.go
} // Special case: -1 for either completions or parallelism means leave nil (negative is not allowed // in practice by validation. if completions >= 0 { j.Spec.Completions = &completions } else { j.Spec.Completions = nil } if parallelism >= 0 { j.Spec.Parallelism = ¶llelism } else { j.Spec.Parallelism = nil } j.Spec.BackoffLimit = &backoffLimit return j }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/scheduler/scheduler.go
return func(o *schedulerOptions) { o.profiles = p o.applyDefaultProfile = false } } // WithParallelism sets the parallelism for all scheduler algorithms. Default is 16. func WithParallelism(threads int32) Option { return func(o *schedulerOptions) { o.parallelism = threads } } // WithPercentageOfNodesToScore sets percentageOfNodesToScore for Scheduler.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 20.8K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/types.go
// be less than this number when ((.spec.completions - .status.successful) < .spec.parallelism), // i.e. when the work left to do is less than max parallelism. // More info: https://kubernetes.io/docs/concepts/workloads/controllers/jobs-run-to-completion/ // +optional Parallelism *int32 `json:"parallelism,omitempty" protobuf:"varint,1,opt,name=parallelism"` // Specifies the desired number of successfully finished pods the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 18:37:07 UTC 2024 - 40.6K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/types_swagger_doc_generated.go
"parallelism": "Specifies the maximum desired number of pods the job should run at any given time. The actual number of pods running in steady state will be less than this number when ((.spec.completions - .status.successful) < .spec.parallelism), i.e. when the work left to do is less than max parallelism. More info: https://kubernetes.io/docs/concepts/workloads/controllers/jobs-run-to-completion/",...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 27.5K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/generated.proto
// be less than this number when ((.spec.completions - .status.successful) < .spec.parallelism), // i.e. when the work left to do is less than max parallelism. // More info: https://kubernetes.io/docs/concepts/workloads/controllers/jobs-run-to-completion/ // +optional optional int32 parallelism = 1; // Specifies the desired number of successfully finished pods the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 29.1K bytes - Viewed (0) -
pkg/apis/batch/types.go
// i.e. when the work left to do is less than max parallelism. // +optional Parallelism *int32 // Specifies the desired number of successfully finished pods the // job should be run with. Setting to null means that the success of any // pod signals the success of all pods, and allows parallelism to have any positive
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 33K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption_test.go
objs = append(objs, p) } for _, n := range tt.nodes { objs = append(objs, n) } informerFactory := informers.NewSharedInformerFactory(clientsetfake.NewSimpleClientset(objs...), 0) parallelism := parallelize.DefaultParallelism _, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel() fwk, err := tf.NewFramework( ctx, registeredPlugins, "",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 18.7K bytes - Viewed (0) -
src/runtime/coro.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package runtime import "unsafe" // A coro represents extra concurrency without extra parallelism, // as would be needed for a coroutine implementation. // The coro does not represent a specific coroutine, only the ability // to do coroutine-style control transfers.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:18 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
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 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tf_passes.td
let summary = "Reorder replicated and partitioned input ops."; let description = [{ 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
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 21:18:05 UTC 2024 - 99.6K bytes - Viewed (0)