@@ -512,18 +512,11 @@ func (cc *clusterCache) Reconcile(ctx context.Context, req reconcile.Request) (r
512
512
requeueAfterDurations = append (requeueAfterDurations , accessor .config .HealthProbe .Interval )
513
513
}
514
514
}
515
- }
516
-
517
- // Send events to cluster sources.
518
- lastProbeSuccessTime := accessor .GetLastProbeSuccessTimestamp (ctx )
519
- cc .sendEventsToClusterSources (ctx , cluster , time .Now (), lastProbeSuccessTime , didConnect , didDisconnect )
520
515
521
- // Check if kubeconfig was updated (only when connected).
522
- if connected {
516
+ // Check if kubeconfig was updated
523
517
kubeconfigUpdated , err := accessor .KubeConfigUpdated (ctx )
524
518
if err != nil {
525
519
log .Error (err , "error checking if kubeconfig was updated" )
526
- // Don't return error here, just log it and continue
527
520
} else if kubeconfigUpdated {
528
521
log .Info ("Kubeconfig was updated, disconnecting to re-connect with the new kubeconfig" )
529
522
accessor .Disconnect (ctx )
@@ -532,6 +525,10 @@ func (cc *clusterCache) Reconcile(ctx context.Context, req reconcile.Request) (r
532
525
}
533
526
}
534
527
528
+ // Send events to cluster sources.
529
+ lastProbeSuccessTime := accessor .GetLastProbeSuccessTimestamp (ctx )
530
+ cc .sendEventsToClusterSources (ctx , cluster , time .Now (), lastProbeSuccessTime , didConnect , didDisconnect )
531
+
535
532
// Requeue based on requeueAfterDurations (fallback to defaultRequeueAfter).
536
533
return reconcile.Result {RequeueAfter : minDurationOrDefault (requeueAfterDurations , defaultRequeueAfter )}, nil
537
534
}
0 commit comments