diff --git a/openmeter/entitlement/balanceworker/recalculate.go b/openmeter/entitlement/balanceworker/recalculate.go index a36b453be..848789871 100644 --- a/openmeter/entitlement/balanceworker/recalculate.go +++ b/openmeter/entitlement/balanceworker/recalculate.go @@ -147,7 +147,7 @@ func (r *Recalculator) processEntitlements(ctx context.Context, entitlements []e } func (r *Recalculator) sendEntitlementEvent(ctx context.Context, ent entitlement.Entitlement) error { - if ent.DeletedAt != nil { + if ent.DeletedAt != nil || (ent.ActiveTo != nil && time.Now().After(*ent.ActiveTo)) { return r.sendEntitlementDeletedEvent(ctx, ent) }