Return the context error

Signed-off-by: Michel Hollands <[email protected]>

Author: MichelHollands

pkg/admission/annotations.go

@@ -20,7 +20,7 @@ const (
 func addDownscaledAnnotationToStatefulSet(ctx context.Context, api kubernetes.Interface, namespace, stsName string) error {
 	select {
 	case <-ctx.Done():
-		return fmt.Errorf("context cancelled")
+		return ctx.Err()
 	default:
 	}
 
@@ -39,7 +39,7 @@ type statefulSet struct {
 func findDownscalesDoneMinTimeAgo(ctx context.Context, api kubernetes.Interface, namespace, stsName, rolloutGroup string) (*statefulSet, error) {
 	select {
 	case <-ctx.Done():
-		return nil, fmt.Errorf("context cancelled")
+		return nil, ctx.Err()
 	default:
 	}
 	client := api.AppsV1().StatefulSets(namespace)

pkg/admission/no_downscale.go

@@ -142,7 +142,7 @@ func allowErr(logger log.Logger, msg string, err error) *v1.AdmissionResponse {
 func getResourceLabels(ctx context.Context, ar v1.AdmissionReview, api kubernetes.Interface) (map[string]string, error) {
 	select {
 	case <-ctx.Done():
-		return nil, fmt.Errorf("context cancelled")
+		return nil, ctx.Err()
 	default:
 	}
 

pkg/admission/prep_downscale.go

@@ -41,7 +41,7 @@ type httpClient interface {
 func prepareDownscale(ctx context.Context, logger log.Logger, ar v1.AdmissionReview, api kubernetes.Interface, client httpClient) *v1.AdmissionResponse {
 	select {
 	case <-ctx.Done():
-		return deny("context cancelled")
+		return deny(ctx.Err().Error())
 	default:
 	}
 
@@ -261,7 +261,7 @@ func deny(msg string, args ...any) *v1.AdmissionResponse {
 func getResourceAnnotations(ctx context.Context, ar v1.AdmissionReview, api kubernetes.Interface) (map[string]string, error) {
 	select {
 	case <-ctx.Done():
-		return nil, fmt.Errorf("context cancelled")
+		return nil, ctx.Err()
 	default:
 	}