Update status

streamnative · Sep 13, 2024 · ad35675 · ad35675
1 parent 36a0498
commit ad35675
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/controllers/function_controller.go b/controllers/function_controller.go
@@ -107,6 +107,11 @@ func (r *FunctionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
 	}
 	// skip reconcile if pauseRollout is set to true and the generation is not increased
 	if spec.IsPauseRollout(function) && !isNewGeneration {
+		err = r.Status().Update(ctx, function)
+		if err != nil {
+			r.Log.Error(err, "failed to update function status after observing statefulset")
+			return ctrl.Result{}, err
+		}
 		return ctrl.Result{}, nil
 	}
 

diff --git a/controllers/sink_controller.go b/controllers/sink_controller.go
@@ -106,6 +106,11 @@ func (r *SinkReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.
 	}
 	// skip reconcile if pauseRollout is set to true and the generation is not increased
 	if spec.IsPauseRollout(sink) && !isNewGeneration {
+		err = r.Status().Update(ctx, sink)
+		if err != nil {
+			r.Log.Error(err, "failed to update sink status after observing statefulset")
+			return ctrl.Result{}, err
+		}
 		return ctrl.Result{}, nil
 	}
 

diff --git a/controllers/source_controller.go b/controllers/source_controller.go
@@ -106,6 +106,11 @@ func (r *SourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctr
 	}
 	// skip reconcile if pauseRollout is set to true and the generation is not increased
 	if spec.IsPauseRollout(source) && !isNewGeneration {
+		err = r.Status().Update(ctx, source)
+		if err != nil {
+			r.Log.Error(err, "failed to update source status after observing statefulset")
+			return ctrl.Result{}, err
+		}
 		return ctrl.Result{}, nil
 	}