JobCR will warning when STSDisabled (#2097)

JobCR will warning if STSDisabled JobCR will warning if STSDisabled
minio · Apr 30, 2024 · 010b890 · 010b890
1 parent 276cb27
commit 010b890
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/pkg/controller/job-controller.go b/pkg/controller/job-controller.go
@@ -31,6 +31,7 @@ import (
 	joblisters "github.com/minio/operator/pkg/client/listers/job.min.io/v1alpha1"
 	"github.com/minio/operator/pkg/utils/miniojob"
 	batchjobv1 "k8s.io/api/batch/v1"
+	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/api/meta"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -206,6 +207,12 @@ func (c *JobController) SyncHandler(key string) (Result, error) {
 		}
 		return WrapResult(Result{}, err)
 	}
+
+	if !IsSTSEnabled() {
+		c.recorder.Eventf(&jobCR, corev1.EventTypeWarning, "STSDisabled", "JobCR cannot work with STS disabled")
+		return WrapResult(Result{}, nil)
+	}
+
 	// if job cr is Success, do nothing
 	if jobCR.Status.Phase == miniojob.MinioJobPhaseSuccess {
 		// delete the job status