test/Rainbond
1
0
Fork 0
mirror of https://gitee.com/rainbond/Rainbond.git synced 2024-12-01 11:18:08 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

remove wrong ctx.Done()

Browse Source
This commit is contained in:
凡羊羊 2020-03-03 12:25:21 +08:00
parent 54427b8889
commit c16cfe05ce
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
builder/build/code_build.go
View File

@ -393,7 +393,6 @@ func waitOldJobDeleted(ctx context.Context, waitChan chan struct{}, clientset ku
jobWatch, err := clientset.BatchV1().Jobs(namespace).Watch(metav1.ListOptions{LabelSelector: labelSelector})
if err != nil {
logrus.Errorf("watch job: %s failed: %s", name, err.Error())
ctx.Done()
return
}
@ -426,7 +425,6 @@ func getJob(ctx context.Context, podChan chan struct{}, clientset kubernetes.Int
jobWatch, err := clientset.BatchV1().Jobs(namespace).Watch(metav1.ListOptions{LabelSelector: labelSelector})
if err != nil {
logrus.Errorf("watch job: %s failed: %s", name, err.Error())
ctx.Done()
return
}
@ -475,7 +473,6 @@ func waitPod(ctx context.Context, podChan chan struct{}, clientset kubernetes.In
labelSelector := fmt.Sprintf("job-name=%s", name)
podWatch, err := clientset.CoreV1().Pods(namespace).Watch(metav1.ListOptions{LabelSelector: labelSelector})
if err != nil {
ctx.Done()
return
}