mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-28 05:57:25 +00:00
Merge pull request #110771 from alculquicondor/increase_timeout
Wait for cache sync in TestSyncPastDeadlineJobFinished
This commit is contained in:
commit
11686e1386
@ -1840,6 +1840,7 @@ func TestSyncPastDeadlineJobFinished(t *testing.T) {
|
|||||||
ctx, cancel := context.WithCancel(context.Background())
|
ctx, cancel := context.WithCancel(context.Background())
|
||||||
defer cancel()
|
defer cancel()
|
||||||
sharedInformerFactory.Start(ctx.Done())
|
sharedInformerFactory.Start(ctx.Done())
|
||||||
|
sharedInformerFactory.WaitForCacheSync(ctx.Done())
|
||||||
|
|
||||||
go manager.Run(ctx, 1)
|
go manager.Run(ctx, 1)
|
||||||
|
|
||||||
@ -1878,7 +1879,7 @@ func TestSyncPastDeadlineJobFinished(t *testing.T) {
|
|||||||
t.Fatalf("Failed to insert job in index: %v", err)
|
t.Fatalf("Failed to insert job in index: %v", err)
|
||||||
}
|
}
|
||||||
var j *batch.Job
|
var j *batch.Job
|
||||||
err = wait.Poll(200*time.Millisecond, 10*time.Second, func() (done bool, err error) {
|
err = wait.Poll(200*time.Millisecond, 3*time.Second, func() (done bool, err error) {
|
||||||
j, err = clientset.BatchV1().Jobs(metav1.NamespaceDefault).Get(ctx, job.GetName(), metav1.GetOptions{})
|
j, err = clientset.BatchV1().Jobs(metav1.NamespaceDefault).Get(ctx, job.GetName(), metav1.GetOptions{})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return false, nil
|
return false, nil
|
||||||
|
Loading…
Reference in New Issue
Block a user