fix infinite hang?

rocktavious · rocktavious · commit bbe3213b616c · 2024-12-19T09:38:34.000-06:00
diff --git a/src/pkg/k8s.go b/src/pkg/k8s.go
@@ -444,7 +444,7 @@ func (s *JobRunner) isPodInDesiredState(podConfig *corev1.Pod) wait.ConditionWit
 
 func (s *JobRunner) WaitForPod(podConfig *corev1.Pod, timeout time.Duration) error {
 	s.logger.Debug().Msgf("Waiting for pod %s/%s to be ready in %s ...", podConfig.Namespace, podConfig.Name, timeout)
-	return wait.PollUntilContextCancel(context.TODO(), timeout, false, s.isPodInDesiredState(podConfig))
+	return wait.PollUntilContextTimeout(context.Background(), time.Second, timeout, false, s.isPodInDesiredState(podConfig))
 }
 
 func (s *JobRunner) DeleteConfigMap(config *corev1.ConfigMap) {

Original file line number	Diff line number	Diff line change
`@@ -444,7 +444,7 @@ func (s JobRunner) isPodInDesiredState(podConfig corev1.Pod) wait.ConditionWit`
`444`	`444`
`445`	`445`	`func (s JobRunner) WaitForPod(podConfig corev1.Pod, timeout time.Duration) error {`
`446`	`446`	`s.logger.Debug().Msgf("Waiting for pod %s/%s to be ready in %s ...", podConfig.Namespace, podConfig.Name, timeout)`
`447`		`- return wait.PollUntilContextCancel(context.TODO(), timeout, false, s.isPodInDesiredState(podConfig))`
	`447`	`+ return wait.PollUntilContextTimeout(context.Background(), time.Second, timeout, false, s.isPodInDesiredState(podConfig))`
`448`	`448`	`}`
`449`	`449`
`450`	`450`	`func (s JobRunner) DeleteConfigMap(config corev1.ConfigMap) {`