Trigger NatssChannel reconciliation in case of errors (#764)

knative · Nov 29, 2019 · 690293c · 690293c
1 parent 302c5e0
commit 690293c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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 {