github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-07 11:13:48 +00:00
Code Issues Projects Releases Wiki Activity

support the job controller handles the orphan pod using multi workers

Browse Source
This commit is contained in:
古九 2024-08-07 10:19:16 +08:00 committed by gujiu.fsd
parent 60c4c2b252
commit a1f0fc8f72
2 changed files with 3 additions and 2 deletions
Show Stats 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)