@@ -173,11 +173,11 @@ func (h *eventHandlerImpl) HandleEventBatch(ctx context.Context, logger logr.Log
173
173
case state .EndpointsOnlyChange :
174
174
h .version ++
175
175
cfg := dataplane .BuildConfiguration (ctx , gr , h .cfg .serviceResolver , h .version )
176
- if depCtx , err := h .setDeploymentCtx (ctx , logger ); err != nil {
177
- logger .Error (err , "error setting deployment context for usage reporting" )
178
- } else {
179
- cfg .DeploymentContext = depCtx
176
+ depCtx , setErr := h .setDeploymentCtx (ctx , logger )
177
+ if setErr != nil {
178
+ logger .Error (setErr , "error setting deployment context for usage reporting" )
180
179
}
180
+ cfg .DeploymentContext = depCtx
181
181
182
182
h .setLatestConfiguration (& cfg )
183
183
@@ -189,11 +189,11 @@ func (h *eventHandlerImpl) HandleEventBatch(ctx context.Context, logger logr.Log
189
189
case state .ClusterStateChange :
190
190
h .version ++
191
191
cfg := dataplane .BuildConfiguration (ctx , gr , h .cfg .serviceResolver , h .version )
192
- if depCtx , err := h .setDeploymentCtx (ctx , logger ); err != nil {
193
- logger .Error (err , "error setting deployment context for usage reporting" )
194
- } else {
195
- cfg .DeploymentContext = depCtx
192
+ depCtx , setErr := h .setDeploymentCtx (ctx , logger )
193
+ if setErr != nil {
194
+ logger .Error (setErr , "error setting deployment context for usage reporting" )
196
195
}
196
+ cfg .DeploymentContext = depCtx
197
197
198
198
h .setLatestConfiguration (& cfg )
199
199
@@ -516,14 +516,14 @@ func (h *eventHandlerImpl) setDeploymentCtx(
516
516
517
517
clusterInfo , err := telemetry .CollectClusterInformation (ctx , h .cfg .k8sReader )
518
518
if err != nil {
519
- return dataplane.DeploymentContext {}, fmt .Errorf ("error getting cluster information" )
519
+ return dataplane.DeploymentContext {}, fmt .Errorf ("error getting cluster information: %w" , err )
520
520
}
521
521
522
522
var installationID string
523
523
// InstallationID is not required by the usage API, so if we can't get it, don't return an error
524
524
replicaSet , err := telemetry .GetPodReplicaSet (ctx , h .cfg .k8sReader , podNSName )
525
525
if err != nil {
526
- logger .Error (err , fmt . Sprintf ( "failed to get replica set for pod %v" , podNSName ) )
526
+ logger .Error (err , "failed to get NGF installationID" )
527
527
} else {
528
528
installationID , err = telemetry .GetDeploymentID (replicaSet )
529
529
if err != nil {
0 commit comments