From 690293c82da40152fbb0224ff45d33be67a8af9a Mon Sep 17 00:00:00 2001 From: Marco Bebway Date: Fri, 29 Nov 2019 14:04:22 +0100 Subject: [PATCH] Trigger NatssChannel reconciliation in case of errors (#764) --- natss/pkg/reconciler/dispatcher/natsschannel.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/natss/pkg/reconciler/dispatcher/natsschannel.go b/natss/pkg/reconciler/dispatcher/natsschannel.go index 4999095290..22ed25caff 100644 --- a/natss/pkg/reconciler/dispatcher/natsschannel.go +++ b/natss/pkg/reconciler/dispatcher/natsschannel.go @@ -130,7 +130,9 @@ func (r *Reconciler) Reconcile(ctx context.Context, key string) error { logging.FromContext(ctx).Error("Failed to update NatssChannel status", zap.Error(updateStatusErr)) return updateStatusErr } - return nil + + // Trigger reconciliation in case of errors + return reconcileErr } func (r *Reconciler) reconcile(ctx context.Context, natssChannel *v1alpha1.NatssChannel) error {