Skip to content

Commit 1c577c9

Browse files
Merge pull request #459 from stuggi/fix_RequeueAfter
Return nil error in case NotFound and to use RequeueAfter
2 parents f89653c + c14a169 commit 1c577c9

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

controllers/keystoneapi_controller.go

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -715,12 +715,13 @@ func (r *KeystoneAPIReconciler) reconcileNormal(
715715
ospSecret, hash, err := oko_secret.GetSecret(ctx, helper, instance.Spec.Secret, instance.Namespace)
716716
if err != nil {
717717
if k8s_errors.IsNotFound(err) {
718+
Log.Info(fmt.Sprintf("OpenStack secret %s not found", instance.Spec.Secret))
718719
instance.Status.Conditions.Set(condition.FalseCondition(
719720
condition.InputReadyCondition,
720721
condition.RequestedReason,
721722
condition.SeverityInfo,
722723
condition.InputReadyWaitingMessage))
723-
return ctrl.Result{RequeueAfter: time.Second * 10}, fmt.Errorf("OpenStack secret %s not found", instance.Spec.Secret)
724+
return ctrl.Result{RequeueAfter: time.Second * 10}, nil
724725
}
725726
instance.Status.Conditions.Set(condition.FalseCondition(
726727
condition.InputReadyCondition,
@@ -785,12 +786,13 @@ func (r *KeystoneAPIReconciler) reconcileNormal(
785786
memcached, err := memcachedv1.GetMemcachedByName(ctx, helper, instance.Spec.MemcachedInstance, instance.Namespace)
786787
if err != nil {
787788
if k8s_errors.IsNotFound(err) {
789+
Log.Info(fmt.Sprintf("memcached %s not found", instance.Spec.MemcachedInstance))
788790
instance.Status.Conditions.Set(condition.FalseCondition(
789791
condition.MemcachedReadyCondition,
790792
condition.RequestedReason,
791793
condition.SeverityInfo,
792794
condition.MemcachedReadyWaitingMessage))
793-
return ctrl.Result{RequeueAfter: 10 * time.Second}, fmt.Errorf("memcached %s not found", instance.Spec.MemcachedInstance)
795+
return ctrl.Result{RequeueAfter: 10 * time.Second}, nil
794796
}
795797
instance.Status.Conditions.Set(condition.FalseCondition(
796798
condition.MemcachedReadyCondition,
@@ -816,12 +818,13 @@ func (r *KeystoneAPIReconciler) reconcileNormal(
816818
}
817819

818820
if !memcached.IsReady() {
821+
Log.Info(fmt.Sprintf("memcached %s is not ready", memcached.Name))
819822
instance.Status.Conditions.Set(condition.FalseCondition(
820823
condition.MemcachedReadyCondition,
821824
condition.RequestedReason,
822825
condition.SeverityInfo,
823826
condition.MemcachedReadyWaitingMessage))
824-
return ctrl.Result{RequeueAfter: 10 * time.Second}, fmt.Errorf("memcached %s is not ready", memcached.Name)
827+
return ctrl.Result{RequeueAfter: 10 * time.Second}, nil
825828
}
826829
// Mark the Memcached Service as Ready if we get to this point with no errors
827830
instance.Status.Conditions.MarkTrue(
@@ -935,13 +938,14 @@ func (r *KeystoneAPIReconciler) reconcileNormal(
935938
_, err := nad.GetNADWithName(ctx, helper, netAtt, instance.Namespace)
936939
if err != nil {
937940
if k8s_errors.IsNotFound(err) {
941+
Log.Info(fmt.Sprintf("network-attachment-definition %s not found", netAtt))
938942
instance.Status.Conditions.Set(condition.FalseCondition(
939943
condition.NetworkAttachmentsReadyCondition,
940944
condition.RequestedReason,
941945
condition.SeverityInfo,
942946
condition.NetworkAttachmentsReadyWaitingMessage,
943947
netAtt))
944-
return ctrl.Result{RequeueAfter: time.Second * 10}, fmt.Errorf("network-attachment-definition %s not found", netAtt)
948+
return ctrl.Result{RequeueAfter: time.Second * 10}, nil
945949
}
946950
instance.Status.Conditions.Set(condition.FalseCondition(
947951
condition.NetworkAttachmentsReadyCondition,

0 commit comments

Comments
 (0)