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,