From 08f242e98d325c791a6401bebdde9545b8891565 Mon Sep 17 00:00:00 2001 From: Elio Bischof Date: Tue, 11 Jul 2023 12:10:37 +0200 Subject: [PATCH] perf: skip already pushed check (#6164) Co-authored-by: Livio Spring --- internal/notification/handlers/telemetry_pusher.go | 8 -------- 1 file changed, 8 deletions(-) diff --git a/internal/notification/handlers/telemetry_pusher.go b/internal/notification/handlers/telemetry_pusher.go index 000bbe1c7f..86f8420c72 100644 --- a/internal/notification/handlers/telemetry_pusher.go +++ b/internal/notification/handlers/telemetry_pusher.go @@ -122,14 +122,6 @@ func (t *telemetryPusher) pushMilestones(event eventstore.Event) (*handler.State func (t *telemetryPusher) pushMilestone(ctx context.Context, event *pseudo.ScheduledEvent, ms *query.Milestone) error { ctx = authz.WithInstanceID(ctx, ms.InstanceID) - alreadyHandled, err := t.queries.IsAlreadyHandled(ctx, event, map[string]interface{}{"type": ms.Type.String()}, milestone.AggregateType, milestone.PushedEventType) - if err != nil { - return err - } - if alreadyHandled { - return nil - } - for _, endpoint := range t.cfg.Endpoints { if err := types.SendJSON( ctx,