chore: suppress context.DeadlineExceeded errors in the api event publishing (#2171)

Signed-off-by: Alessandro Yuichi Okimoto <yuichijpn@gmail.com>

Author: cre8ivejp

pkg/api/api/api.go

@@ -819,7 +819,7 @@ func (s *gatewayService) registerEvents(w http.ResponseWriter, req *http.Request
 			} else {
 				nonRepeateableErrors++
 			}
-			if !errors.Is(err, context.Canceled) {
+			if !errors.Is(err, context.Canceled) && !errors.Is(err, context.DeadlineExceeded) {
 				s.logger.Error(
 					"Failed to publish event",
 					log.FieldsFromIncomingContext(req.Context()).AddFields(

pkg/api/api/api_grpc.go

@@ -1319,7 +1319,7 @@ func (s *grpcGatewayService) RegisterEvents(
 			} else {
 				nonRepeateableErrors++
 			}
-			if !errors.Is(err, context.Canceled) {
+			if !errors.Is(err, context.Canceled) && !errors.Is(err, context.DeadlineExceeded) {
 				s.logger.Error(
 					"Failed to publish event",
 					log.FieldsFromIncomingContext(ctx).AddFields(

pkg/batch/jobs/calculator/experiment_calculate.go

@@ -107,7 +107,6 @@ func (e *experimentCalculate) runCalculation() {
 	ctxWithTimeout, cancel := context.WithTimeout(context.Background(), e.opts.Timeout)
 	defer cancel() // Ensure context is canceled when goroutine completes
 	var err error
-	e.logger.Info("Started experiment calculation job")
 	startTime := time.Now().In(e.location)
 	defer func() {
 		jobs.RecordJob(jobs.JobExperimentCalculator, err, time.Since(startTime))

pkg/rpc/gateway/gateway.go

@@ -424,10 +424,6 @@ func (g *Gateway) Stop(timeout time.Duration) {
 				zap.Duration("timeout", timeout),
 				zap.Duration("elapsed", time.Since(startTime)),
 			)
-		} else {
-			g.logger.Info("HTTP grpc-gateway server shutdown completed",
-				zap.Duration("elapsed", time.Since(startTime)),
-			)
 		}
 	}
 }

pkg/subscriber/processor/evaluation_events_evaluation_count_event_persister.go

@@ -361,11 +361,10 @@ func (p *evaluationCountEventPersister) cacheEnvLastUsedInfo(
 	p.envLastUsedCacheMutex.Lock()
 	defer p.envLastUsedCacheMutex.Unlock()
 	var clientVersion string
-	if event.User == nil {
-		p.logger.Warn("Failed to cache last used info. User is nil.",
-			zap.String("environmentId", environmentId))
-	} else {
-		clientVersion = event.User.Data[userDataAppVersion]
+	if event.User != nil {
+		if version, ok := event.User.Data[userDataAppVersion]; ok {
+			clientVersion = version
+		}
 	}
 	id := ftdomain.FeatureLastUsedInfoID(event.FeatureId, event.FeatureVersion)
 	if cache, ok := p.envLastUsedCache[environmentId]; ok {