- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 130 for Parallelism (0.31 sec)
-
pkg/apis/batch/v1/defaults_test.go
t.Errorf(".spec.suspend does not match; -want,+got:\n%s", diff) } validateDefaultInt32(t, "Completions", actual.Spec.Completions, expected.Spec.Completions) validateDefaultInt32(t, "Parallelism", actual.Spec.Parallelism, expected.Spec.Parallelism) validateDefaultInt32(t, "BackoffLimit", actual.Spec.BackoffLimit, expected.Spec.BackoffLimit) if diff := cmp.Diff(expected.Spec.PodFailurePolicy, actual.Spec.PodFailurePolicy); diff != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 20.8K bytes - Viewed (0) -
pkg/apis/batch/v1/defaults.go
// For a non-parallel job, you can leave both `.spec.completions` and // `.spec.parallelism` unset. When both are unset, both are defaulted to 1. if obj.Spec.Completions == nil && obj.Spec.Parallelism == nil { obj.Spec.Completions = utilpointer.Int32(1) obj.Spec.Parallelism = utilpointer.Int32(1) } if obj.Spec.Parallelism == nil { obj.Spec.Parallelism = utilpointer.Int32(1) } if obj.Spec.BackoffLimit == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 11 20:51:40 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/scheduler/apis/config/v1/defaults_test.go
SchedulerName: ptr.To("default-scheduler"), }, }, }, }, { name: "set non default parallelism", config: &configv1.KubeSchedulerConfiguration{ Parallelism: ptr.To[int32](8), }, expected: &configv1.KubeSchedulerConfiguration{ Parallelism: ptr.To[int32](8), DebuggingConfiguration: componentbaseconfig.DebuggingConfiguration{ EnableProfiling: &enable,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 15:03:04 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/api/job/warnings.go
completions := ptr.Deref(spec.Completions, 0) parallelism := ptr.Deref(spec.Parallelism, 0) if completions > completionsSoftLimit && parallelism > parallelismSoftLimitForUnlimitedCompletions { msg := "In Indexed Jobs with a number of completions higher than 10^5 and a parallelism higher than 10^4, Kubernetes might not be able to track completedIndexes when a big number of indexes fail"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 24 11:44:07 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/registry/batch/job/storage/storage_test.go
} return &jobStorage, server } func validNewJob() *batch.Job { completions := int32(1) parallelism := int32(1) return &batch.Job{ ObjectMeta: metav1.ObjectMeta{ Name: "foo", Namespace: "default", }, Spec: batch.JobSpec{ Completions: &completions, Parallelism: ¶llelism, Selector: &metav1.LabelSelector{ MatchLabels: map[string]string{"a": "b"}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 11.2K bytes - Viewed (0) -
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/apis/batch/fuzzer/fuzzer.go
func(j *batch.JobSpec, c fuzz.Continue) { c.FuzzNoCustom(j) // fuzz self without calling this function again completions := int32(c.Rand.Int31()) parallelism := int32(c.Rand.Int31()) backoffLimit := int32(c.Rand.Int31()) j.Completions = &completions j.Parallelism = ¶llelism j.BackoffLimit = &backoffLimit j.ManualSelector = pointer.Bool(c.RandBool()) mode := batch.NonIndexedCompletion if c.RandBool() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 17:25:15 UTC 2024 - 3K bytes - Viewed (0) -
hack/make-rules/test-e2e-node.sh
# fail due to resource contention. 8 is a reasonable default for a # e2-standard-2 node. # Currently, parallelism only affects when REMOTE=true. For local test, # ginkgo default parallelism (cores - 1) is used. parallelism=${PARALLELISM:-8} artifacts="${ARTIFACTS:-"/tmp/_artifacts/$(date +%y%m%dT%H%M%S)"}" remote=${REMOTE:-"false"} remote_mode=${REMOTE_MODE:-"gce"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 09:46:28 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/scheduler/apis/config/validation/validation_test.go
wantErrs field.ErrorList }{ "good": { config: validConfig, }, "bad-parallelism-invalid-value": { config: invalidParallelismValue, wantErrs: field.ErrorList{ &field.Error{ Type: field.ErrorTypeInvalid, Field: "parallelism", }, }, }, "bad-resource-name-not-set": { config: resourceNameNotSet, wantErrs: field.ErrorList{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 06:27:01 UTC 2024 - 12.2K bytes - Viewed (0) -
pkg/registry/batch/job/strategy_test.go
Template: validPodTemplateSpec, Parallelism: ptr.To[int32](4), }, Status: batch.JobStatus{ Active: 12, }, }, }, "parallelism changes not allowed": { job: &batch.Job{ ObjectMeta: validObjectMeta, Spec: batch.JobSpec{ Selector: validSelector, Template: validPodTemplateSpec, Parallelism: ptr.To[int32](3), }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 101.5K bytes - Viewed (0)