- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 148 for Parallelism (0.42 sec)
-
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) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/MissingTaskDependenciesIntegrationTest.groovy
when: run("filteredConsumer", "producer") then: skipped(":producer", ":filteredConsumer") } @ToBeFixedForConfigurationCache(skip = FLAKY, because = "Due to extra parallelism with cc missing dependencies detection can be flaky") def "fails when missing dependencies using filtered inputs"() { file("src/main/java/MyClass.java").createFile() buildFile """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 08:14:44 UTC 2024 - 20.3K bytes - Viewed (0) -
src/cmd/go/internal/work/gc.go
// We do this now when p==1. // To limit parallelism, set GOMAXPROCS below numCPU; this may be useful // on a low-memory builder, or if a deterministic build order is required. c := runtime.GOMAXPROCS(0) if cfg.BuildP == 1 { // No process parallelism, do not cap compiler parallelism. return c } // Some process parallelism. Set c to min(4, maxprocs). if c > 4 { c = 4 } return c
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 15:37:44 UTC 2024 - 23K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/tpu-variable-runtime-reformatting.mlir
}) {device = "", is_stateless = false} : (tensor<i32>) -> (tensor<i32>) func.return } } // ----- // Tests that the pass does not format variables when model parallelism is // present. Model parallelism is present when there is more than 1 // TPUExecuteAndUpdateVariables in a parallel_execute. !tf_res_f32 = tensor<*x!tf_type.resource<tensor<f32>>>
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Oct 31 08:59:10 UTC 2023 - 25.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/convert_control_to_data_outputs.cc
// trait, then we don't need to chain resource ops accessing this resource // between iterations: Every iteration will create a new independent // resource. This enables more parallelism across iterations. if (!side_effect_analysis.IsUniqueResourceAllocationId( resource_and_device.first)) { chain_resource_to_ops_map[resource_and_device].insert(&op);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 28.7K bytes - Viewed (0) -
pkg/scheduler/apis/config/v1/zz_generated.conversion.go
if err := metav1.Convert_Pointer_int32_To_int32(&in.Parallelism, &out.Parallelism, s); err != nil { return err } if err := v1alpha1.Convert_v1alpha1_LeaderElectionConfiguration_To_config_LeaderElectionConfiguration(&in.LeaderElection, &out.LeaderElection, s); err != nil { return err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 18:47:23 UTC 2024 - 46.9K 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) -
pkg/registry/batch/job/strategy.go
return batchvalidation.JobStatusValidationOptions{ // We allow to decrease the counter for succeeded pods for jobs which // have equal parallelism and completions, as they can be scaled-down. RejectDecreasingSucceededCounter: !isIndexed || !ptr.Equal(newJob.Spec.Completions, newJob.Spec.Parallelism), RejectDecreasingFailedCounter: true, RejectDisablingTerminalCondition: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 16:43:24 UTC 2024 - 18.4K bytes - Viewed (0) -
src/sync/oncefunc_test.go
package sync_test import ( "bytes" "math" "runtime" "runtime/debug" "sync" "sync/atomic" "testing" _ "unsafe" ) // We assume that the Once.Do tests have already covered parallelism. func TestOnceFunc(t *testing.T) { calls := 0 f := sync.OnceFunc(func() { calls++ }) allocs := testing.AllocsPerRun(10, f) if calls != 1 { t.Errorf("want calls==1, got %d", calls) } if allocs != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 17:31:33 UTC 2023 - 6.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/g3doc/_includes/tf_passes.md
### `-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
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 02 02:26:39 UTC 2023 - 96.4K bytes - Viewed (0)