async def METHOD_NAME(
    cls, session: ProfileSession, connection_id: str
) -> bool:
    """Return whether a discovery exchange record exists for the given connection.
    Args:
        session (ProfileSession): session
        connection_id (str): connection_id
    Returns:
        bool: whether record exists
    """
    tag_filter = {"connection_id": connection_id}
    try:
        record = await cls.retrieve_by_tag_filter(session, tag_filter)
    except StorageNotFoundError:
        return False
    except StorageDuplicateError:
        return True
    return bool(record)