def METHOD_NAME(
    entity_key: EntityKey,
    query: Union[CompositeQuery[QueryEntity], Query],
    metadata: Mapping[str, Any],
    exception: Optional[Type[Exception]],
    offset: Optional[int],
) -> None:
    entity = get_entity(entity_key)
    subscription_validators = entity.get_subscription_validators()
    if subscription_validators:
        for validator in subscription_validators:
            if isinstance(validator, AggregationValidator):
                validator.validate(query)