Skip to content
This repository was archived by the owner on Aug 29, 2022. It is now read-only.

Commit 0a91509

Browse files
committed
Don't hang when cert request gets deleted
1 parent 365138c commit 0a91509

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

certreq.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ import (
1010
"fmt"
1111
"io/ioutil"
1212
certificates "k8s.io/api/certificates/v1beta1"
13+
"k8s.io/apimachinery/pkg/api/errors"
1314
metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
1415
"k8s.io/client-go/kubernetes"
1516
"log"
@@ -103,6 +104,10 @@ func requestCertificate(client kubernetes.Interface, labels map[string]string, d
103104

104105
for {
105106
csr, err := client.CertificatesV1beta1().CertificateSigningRequests().Get(context.TODO(), certificateSigningRequestName, metaV1.GetOptions{})
107+
if errors.IsNotFound(err) {
108+
// If the request got deleted, waiting won't help.
109+
log.Fatalf("certificate signing request (%s) not found", certificateSigningRequestName)
110+
}
106111
if err != nil {
107112
log.Printf("unable to retrieve certificate signing request (%s): %s", certificateSigningRequestName, err)
108113
time.Sleep(5 * time.Second)

0 commit comments

Comments
 (0)