@@ -173,11 +173,11 @@ func (h *eventHandlerImpl) HandleEventBatch(ctx context.Context, logger logr.Log
173173 case state .EndpointsOnlyChange :
174174 h .version ++
175175 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" )
180179 }
180+ cfg .DeploymentContext = depCtx
181181
182182 h .setLatestConfiguration (& cfg )
183183
@@ -189,11 +189,11 @@ func (h *eventHandlerImpl) HandleEventBatch(ctx context.Context, logger logr.Log
189189 case state .ClusterStateChange :
190190 h .version ++
191191 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" )
196195 }
196+ cfg .DeploymentContext = depCtx
197197
198198 h .setLatestConfiguration (& cfg )
199199
@@ -516,14 +516,14 @@ func (h *eventHandlerImpl) setDeploymentCtx(
516516
517517 clusterInfo , err := telemetry .CollectClusterInformation (ctx , h .cfg .k8sReader )
518518 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 )
520520 }
521521
522522 var installationID string
523523 // InstallationID is not required by the usage API, so if we can't get it, don't return an error
524524 replicaSet , err := telemetry .GetPodReplicaSet (ctx , h .cfg .k8sReader , podNSName )
525525 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" )
527527 } else {
528528 installationID , err = telemetry .GetDeploymentID (replicaSet )
529529 if err != nil {
0 commit comments