Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for Succeeded (0.27 sec)

  1. pkg/controller/job/job_controller_test.go

    			succeededPods, failedPods := getNewFinishedPods(jobCtx)
    			succeeded := int32(len(succeededPods)) + tc.job.Status.Succeeded + int32(len(uncounted.succeeded))
    			failed := int32(len(failedPods)) + tc.job.Status.Failed + int32(len(uncounted.failed))
    			if succeeded != tc.wantSucceeded {
    				t.Errorf("getStatus reports %d succeeded pods, want %d", succeeded, tc.wantSucceeded)
    			}
    			if failed != tc.wantFailed {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  2. pkg/volume/util/operationexecutor/operation_generator.go

    		simpleMsg, _ := volumeToAttach.GenerateMsg("AttachVolume.Attach succeeded", "")
    		for _, pod := range volumeToAttach.ScheduledPods {
    			og.recorder.Eventf(pod, v1.EventTypeNormal, kevents.SuccessfulAttachVolume, simpleMsg)
    		}
    		klog.Infof(volumeToAttach.GenerateMsgDetailed("AttachVolume.Attach succeeded", ""))
    
    		// Update actual state of world
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/batch/v1/generated.pb.go

    			i--
    			dAtA[i] = 0x12
    		}
    	}
    	if len(m.Succeeded) > 0 {
    		for iNdEx := len(m.Succeeded) - 1; iNdEx >= 0; iNdEx-- {
    			i -= len(m.Succeeded[iNdEx])
    			copy(dAtA[i:], m.Succeeded[iNdEx])
    			i = encodeVarintGenerated(dAtA, i, uint64(len(m.Succeeded[iNdEx])))
    			i--
    			dAtA[i] = 0xa
    		}
    	}
    	return len(dAtA) - i, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 133K bytes
    - Viewed (0)
  4. pkg/registry/batch/job/strategy_test.go

    			enableJobManagedBy: true,
    			job: &batch.Job{
    				ObjectMeta: validObjectMeta,
    			},
    			newJob: &batch.Job{
    				ObjectMeta: validObjectMeta,
    				Status: batch.JobStatus{
    					StartTime:      &now,
    					CompletionTime: &now,
    					UncountedTerminatedPods: &batch.UncountedTerminatedPods{
    						Succeeded: []types.UID{"a"},
    					},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 101.5K bytes
    - Viewed (0)
  5. pkg/apis/batch/validation/validation_test.go

    						Succeeded: []types.UID{"a", "b", "c", "a", ""},
    						Failed:    []types.UID{"c", "d", "e", "d", ""},
    					},
    				},
    			},
    			wantErrs: field.ErrorList{
    				{Type: field.ErrorTypeDuplicate, Field: "status.uncountedTerminatedPods.succeeded[3]"},
    				{Type: field.ErrorTypeInvalid, Field: "status.uncountedTerminatedPods.succeeded[4]"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 124.3K bytes
    - Viewed (0)
  6. pkg/printers/internalversion/printers_test.go

    						{Name: "restartable-init-2", RestartPolicy: &containerRestartPolicyAlways},
    					}, Containers: make([]api.Container, 1)},
    				Status: api.PodStatus{
    					Phase: "Succeeded",
    					InitContainerStatuses: []api.ContainerStatus{
    						{
    							Name:                 "restartable-init-1",
    							Ready:                false,
    							RestartCount:         3,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_pods_test.go

    						succeededState("containerA"),
    						succeededState("containerB"),
    					},
    				},
    			},
    			true,
    			v1.PodSucceeded,
    			"all regular containers succeeded and restartable init container succeeded with restart always, but the pod is terminal",
    		},
    	}
    	featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.SidecarContainers, true)
    	for _, test := range tests {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_pods.go

    				if stopped == succeeded {
    					return v1.PodSucceeded
    				}
    				// There is at least one failure
    				return v1.PodFailed
    			}
    		}
    		// All containers are terminated
    		if spec.RestartPolicy == v1.RestartPolicyAlways {
    			// All containers are in the process of restarting
    			return v1.PodRunning
    		}
    		if stopped == succeeded {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  9. tensorflow/compiler/mlir/lite/ir/tfl_ops.cc

            /*op=*/op.getOperation(), /*indices=*/ArrayRef<unsigned>{0, 1},
            /*max_bcast_rank=*/6);
      }
    
      // Allows QI16 output when operands have the same shape.
      if (IsQI16Type(element_type)) {
        return succeeded(mlir::verifyCompatibleShape(op.getLhs().getType(),
                                                     op.getRhs().getType()));
      }
      return false;
    }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu May 02 09:41:17 UTC 2024
    - 169.2K bytes
    - Viewed (0)
  10. 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)
Back to top