- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for Parallelism (0.26 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/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) -
pkg/apis/batch/validation/validation_test.go
Completions: pointer.Int32(2), Parallelism: pointer.Int32(100000), }, }, }, "valid parallelism and maxFailedIndexes for high completions when backoffLimitPerIndex is used": { job: batch.Job{ ObjectMeta: validJobObjectMeta, Spec: batch.JobSpec{ Completions: pointer.Int32(100_000), Parallelism: pointer.Int32(100_000),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 20:49:09 UTC 2024 - 124.3K 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) -
staging/src/k8s.io/api/batch/v1/generated.pb.go
i-- dAtA[i] = 0x18 } if m.Completions != nil { i = encodeVarintGenerated(dAtA, i, uint64(*m.Completions)) i-- dAtA[i] = 0x10 } if m.Parallelism != nil { i = encodeVarintGenerated(dAtA, i, uint64(*m.Parallelism)) i-- dAtA[i] = 0x8 } return len(dAtA) - i, nil } func (m *JobStatus) Marshal() (dAtA []byte, err error) { size := m.Size()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 20:49:09 UTC 2024 - 133K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/tpu_rewrite.mlir
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 02 22:03:30 UTC 2024 - 172.9K bytes - Viewed (0) -
pkg/printers/internalversion/printers.go
completions = fmt.Sprintf("%d/%d", obj.Status.Succeeded, *obj.Spec.Completions) } else { parallelism := int32(0) if obj.Spec.Parallelism != nil { parallelism = *obj.Spec.Parallelism } if parallelism > 1 { completions = fmt.Sprintf("%d/1 of %d", obj.Status.Succeeded, parallelism) } else { completions = fmt.Sprintf("%d/1", obj.Status.Succeeded) } } var jobDuration string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 128.3K bytes - Viewed (0) -
src/database/sql/sql_test.go
const parallelism = 16 db := newTestDB(b, "magicquery") defer closeDB(b, db) db.SetMaxIdleConns(runtime.GOMAXPROCS(0) * parallelism) stmt, err := db.Prepare("SELECT|magicquery|op|op=?,millis=?") if err != nil { b.Fatal(err) } defer stmt.Close() b.SetParallelism(parallelism) b.RunParallel(func(pb *testing.PB) { for pb.Next() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
src/net/http/serve_test.go
func BenchmarkClientServerParallel(b *testing.B) { for _, parallelism := range []int{4, 64} { b.Run(fmt.Sprint(parallelism), func(b *testing.B) { run(b, func(b *testing.B, mode testMode) { benchmarkClientServerParallel(b, parallelism, mode) }, []testMode{http1Mode, https1Mode, http2Mode}) }) } } func benchmarkClientServerParallel(b *testing.B, parallelism int, mode testMode) { b.ReportAllocs()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
src/cmd/go/internal/work/exec.go
b.readySema <- true } } if a == root { close(b.readySema) } } var wg sync.WaitGroup // Kick off goroutines according to parallelism. // If we are using the -n flag (just printing commands) // drop the parallelism to 1, both to make the output // deterministic and because there is no real work anyway. par := cfg.BuildP if cfg.BuildN { par = 1 } for i := 0; i < par; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 14:46:37 UTC 2024 - 105.6K bytes - Viewed (0)