async def METHOD_NAME(profile_id: str) -> Optional[StorageRecord]:
    """
    @throws DuplicatedRecordException
    """
    query = {
        "size": 2,
        "query": {
            "bool": {
                "should": [
                    {
                        "term": {
                            "ids": profile_id
                        }
                    },
                    {
                        "term": {
                            "id": profile_id
                        }
                    }
                ],
                "minimum_should_match": 1
            }
        }
    }
    profile_records = await storage_manager('profile').query(query)
    if profile_records.total > 1:
        raise DuplicatedRecordException("Profile {} id duplicated in the database..".format(profile_id))
    if profile_records == 0:
        return None
    return profile_records.first()