Add error message when watch is throwing an error

gopaytech · Sep 5, 2019 · 0100b14 · 0100b14
1 parent 34a11ec
commit 0100b14
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/app/service/infra/kubernetes/client.go b/internal/app/service/infra/kubernetes/client.go
@@ -195,6 +195,7 @@ func (client *kubernetesClient) WaitForReadyJob(executionName string, waitTime t
 	for i := 0; i < config.KubeWaitForResourcePollCount(); i += 1 {
 		watchJob, watchErr := jobs.Watch(listOptions)
 		if watchErr != nil {
+			err = watchErr
 			continue
 		}
 
@@ -245,12 +246,12 @@ func (client *kubernetesClient) WaitForReadyPod(executionName string, waitTime t
 	for i := 0; i < config.KubeWaitForResourcePollCount(); i += 1 {
 		watchJob, watchErr := kubernetesPods.Watch(listOptions)
 		if watchErr != nil {
+			err = watchErr
 			continue
 		}
 
 		timeoutChan := time.After(waitTime)
 		resultChan := watchJob.ResultChan()
-		defer watchJob.Stop()
 
 		var pod *v1.Pod
 		for {