def METHOD_NAME(
    subscription_query: Optional[str],
    event_type: str,  # pylint: disable=unused-argument
    payload: Any,
    sensitive_fields: SensitiveFieldsMap,
) -> Any:
    if not subscription_query:
        return payload
    graphql_backend = get_default_backend()
    document = graphql_backend.document_from_string(schema, subscription_query)
    if _contain_sensitive_field(document, sensitive_fields):
        return MASK
    return payload