feat: get source retry interval

Signed-off-by: peefy <[email protected]>

Author: Peefy

api/v1alpha1/kclrun_types.go

@@ -284,6 +284,25 @@ func (in KCLRun) GetTimeout() time.Duration {
 	return duration
 }
 
+// GetRetryInterval returns the retry interval
+func (in KCLRun) GetRetryInterval() time.Duration {
+	if in.Spec.RetryInterval != nil {
+		return in.Spec.RetryInterval.Duration
+	}
+	return in.GetRequeueAfter()
+}
+
+// GetRequeueAfter returns the duration after which the KCLRun must be
+// reconciled again.
+func (in KCLRun) GetRequeueAfter() time.Duration {
+	return in.Spec.Interval.Duration
+}
+
+// GetDependsOn returns the list of dependencies across-namespaces.
+func (in KCLRun) GetDependsOn() []meta.NamespacedObjectReference {
+	return in.Spec.DependsOn
+}
+
 // UsePersistentClient returns the configured PersistentClient, or the default
 // of true.
 func (in KCLRun) UsePersistentClient() bool {

internal/controller/kclrun_controller.go

@@ -41,9 +41,11 @@ import (
 	securejoin "github.com/cyphar/filepath-securejoin"
 	"github.com/fluxcd/cli-utils/pkg/kstatus/polling"
 	"github.com/fluxcd/cli-utils/pkg/object"
+	apiacl "github.com/fluxcd/pkg/apis/acl"
 	eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1"
 	"github.com/fluxcd/pkg/apis/meta"
 	"github.com/fluxcd/pkg/http/fetch"
+	"github.com/fluxcd/pkg/runtime/acl"
 	runtimeClient "github.com/fluxcd/pkg/runtime/client"
 	"github.com/fluxcd/pkg/runtime/conditions"
 	"github.com/fluxcd/pkg/runtime/patch"
@@ -150,6 +152,20 @@ func (r *KCLRunReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctr
 
 	source, err := r.getSource(ctx, &obj)
 	if err != nil {
+		conditions.MarkFalse(&obj, meta.ReadyCondition, meta.ArtifactFailedReason, "%s", err)
+		if apierrors.IsNotFound(err) {
+			msg := fmt.Sprintf("Source '%s' not found", obj.Spec.SourceRef.String())
+			log.Info(msg)
+			return ctrl.Result{RequeueAfter: obj.GetRetryInterval()}, nil
+		}
+
+		if acl.IsAccessDenied(err) {
+			conditions.MarkFalse(&obj, meta.ReadyCondition, apiacl.AccessDeniedReason, "%s", err)
+			log.Error(err, "Access denied to cross-namespace source")
+			r.event(&obj, "unknown", eventv1.EventSeverityError, err.Error(), nil)
+			return ctrl.Result{RequeueAfter: obj.GetRetryInterval()}, nil
+		}
+		// Retry with backoff on transient errors.
 		return ctrl.Result{}, err
 	}
 	artifact := source.GetArtifact()