def METHOD_NAME(self, data_source: HubspotDataSource) -> pd.DataFrame:
    headers = {'authorization': f'Bearer {self._get_access_token()}'}
    try:
        query_params = {}
        # The webanalytics endpoint requires an objectType query param
        data = self._handle_pagination(
            HUBSPOT_ENDPOINTS[data_source.dataset], data_source.dataset, query_params, headers
        )
        return pd.json_normalize(data)
    except Exception as e:
        raise HubspotConnectorException(f'retrieve_data failed with: {str(e)}')