github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-10 20:42:26 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #121147 from kannon92/rm-at-least-no-terminating-count

Browse Source 
Remove terminating count from rmAtLeast
This commit is contained in:
Kubernetes Prow Robot 2023-10-18 00:44:51 +02:00 committed by GitHub
commit 6d70013af5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/controller/job/job_controller.go
View File

@ -1494,7 +1494,7 @@ func (jm *Controller) manageJob(ctx context.Context, job *batch.Job, jobCtx *syn
}
}
rmAtLeast := active + terminating - wantActive
rmAtLeast := active - wantActive
if rmAtLeast < 0 {
rmAtLeast = 0
}

22
pkg/controller/job/job_controller_test.go
View File

@ -362,9 +362,10 @@ func TestControllerSyncJob(t *testing.T) {
jobPodReplacementPolicy: true,
terminatingPods: 1,
expectedTerminating: ptr.To[int32](1),
expectedPodPatches: 2,
expectedDeletions: 1,
expectedFailed: 1,
// Removes finalizer and deletes one failed pod
expectedPodPatches: 1,
expectedFailed: 1,
expectedActive: 1,
},
"WQ job: turn on PodReplacementPolicy but not set PodReplacementPolicy": {
parallelism: 1,
@ -393,7 +394,20 @@ func TestControllerSyncJob(t *testing.T) {
expectedPodPatches: 2,
expectedFailed: 2,
},
"more terminating pods than parallelism": {
parallelism: 1,
completions: 1,
backoffLimit: 6,
activePods: 2,
failedPods: 0,
terminatingPods: 4,
podReplacementPolicy: podReplacementPolicy(batch.Failed),
jobPodReplacementPolicy: true,
expectedTerminating: ptr.To[int32](4),
expectedActive: 1,
expectedDeletions: 1,
expectedPodPatches: 1,
},
"too few active pods and active back-off": {
parallelism: 1,
completions: 1,