scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-02 03:08:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #126567 from fusida/refactor-job-controller

Browse Source 
support the job controller handles the orphan pod using multi workers
This commit is contained in:
Kubernetes Prow Robot
2024-08-19 04:57:15 -07:00
committed by GitHub
parent cb7b4ea648 a1f0fc8f72
commit 8db6fc7e3f
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -232,10 +232,9 @@ func (jm *Controller) Run(ctx context.Context, workers int) {
for i := 0; i < workers; i++ {
go wait.UntilWithContext(ctx, jm.worker, time.Second)
go wait.UntilWithContext(ctx, jm.orphanWorker, time.Second)
}
go wait.UntilWithContext(ctx, jm.orphanWorker, time.Second)
<-ctx.Done()
}

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

@@ -7627,6 +7627,8 @@ func TestFinalizerCleanup(t *testing.T) {
// Initialize the controller with 0 workers to make sure the
// pod finalizers are not removed by the "syncJob" function.
go manager.Run(ctx, 0)
// Make sure the pod finalizers are removed by the "orphanWorker" function.
go wait.UntilWithContext(ctx, manager.orphanWorker, time.Second)
// Create a simple Job
job := newJob(1, 1, 1, batch.NonIndexedCompletion)