chore: go mod tidy

Signed-off-by: Ajay Mishra <[email protected]>

Author: XRFXLP

health-monitors/kubernetes-object-monitor/go.mod

@@ -12,6 +12,7 @@ require (
 	google.golang.org/grpc v1.76.0
 	google.golang.org/protobuf v1.36.10
 	k8s.io/api v0.34.1
+	k8s.io/apiextensions-apiserver v0.34.1
 	k8s.io/apimachinery v0.34.1
 	sigs.k8s.io/controller-runtime v0.22.4
 )
@@ -73,7 +74,6 @@ require (
 	gopkg.in/evanphx/json-patch.v4 v4.13.0 // indirect
 	gopkg.in/inf.v0 v0.9.1 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
-	k8s.io/apiextensions-apiserver v0.34.1 // indirect
 	k8s.io/client-go v0.34.1 // indirect
 	k8s.io/klog/v2 v2.130.1 // indirect
 	k8s.io/kube-openapi v0.0.0-20250910181357-589584f1c912 // indirect

health-monitors/kubernetes-object-monitor/pkg/controller/reconciler.go

@@ -150,15 +150,15 @@ func (r *ResourceReconciler) reconcilePolicy(
 	stateKey := r.getStateKey(p, obj)
 
 	r.matchStatesMu.RLock()
-	_, wasMatched := r.matchStates[stateKey]
+	storedNodeName, wasMatched := r.matchStates[stateKey]
 	r.matchStatesMu.RUnlock()
 
 	if matched && !wasMatched {
 		return r.handleUnhealthyTransition(ctx, p, nodeName, stateKey)
 	}
 
 	if !matched && wasMatched {
-		return r.handleHealthyTransition(ctx, p, nodeName, stateKey)
+		return r.handleHealthyTransition(ctx, p, storedNodeName, stateKey)
 	}
 
 	return nil

health-monitors/kubernetes-object-monitor/pkg/controller/reconciler_test.go

@@ -328,6 +328,26 @@ func TestReconciler_CustomResource(t *testing.T) {
 			!event.isHealthy &&
 			event.policy.Name == "gpu-job-failed"
 	}, time.Second, 50*time.Millisecond)
+
+	setup.publisher.publishedEvents = []mockPublishedEvent{}
+
+	require.NoError(t, setup.k8sClient.Delete(setup.ctx, gpuJob))
+
+	result, err = setup.reconciler.Reconcile(setup.ctx, ctrl.Request{
+		NamespacedName: types.NamespacedName{Name: jobName, Namespace: namespace},
+	})
+	assert.NoError(t, err)
+	assert.Equal(t, ctrl.Result{}, result)
+
+	require.Eventually(t, func() bool {
+		if len(setup.publisher.publishedEvents) != 1 {
+			return false
+		}
+		event := setup.publisher.publishedEvents[0]
+		return event.nodeName == nodeName &&
+			event.isHealthy &&
+			event.policy.Name == "gpu-job-failed"
+	}, time.Second, 50*time.Millisecond)
 }
 
 func TestReconciler_ColdStart(t *testing.T) {